QueueConnector

All Superinterfaces:

javax.jms.ExceptionListener

All Known Implementing Classes:

JMSQConnector, QConnector, QConnector
```
public interface QueueConnector
extends javax.jms.ExceptionListener
```
QueueConnector is an Interface for JMS Queue and its Connections

Author:

yannanlu@yahoo.com

Field Summary

Fields
Modifier and Type Field and Description

static int QC_QUEUE

static int QC_STREAM

static int QC_TOPIC

static int QC_XQ

static int XA_CLIENT

static int XA_COMMIT

Fields
Modifier and Type	Field and Description
`static int`	`QC_QUEUE`
`static int`	`QC_STREAM`
`static int`	`QC_TOPIC`
`static int`	`QC_XQ`
`static int`	`XA_CLIENT`
`static int`	`XA_COMMIT`

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`browse(java.lang.Object out)` browses the JMS messages from the JMS queue and puts them to the output, either a queue, a topic, a stream or an XQueue.
`void`	`close()` closes all opened resources
`javax.jms.Message`	`createMessage(int type)` returns a JMS Message with the initialized JMSSession
`javax.jms.Queue`	`createQueue(java.lang.String name)` returns the queue created for the given name
`javax.jms.Queue`	`createTemporaryQueue()` returns the temporary queue created
`void`	`get(java.lang.Object out)` continuously gets the JMS messages from the JMS queue and puts them to the output, either a queue, a topic, a stream or an XQueue.
`java.lang.String`	`getOperation()` returns the string of the operation
`javax.jms.QueueBrowser`	`getQueueBrowser()` returns an on-demand browser in a separate session
`javax.jms.QueueReceiver`	`getQueueReceiver()` returns an on-demand receiver in a separate session
`javax.jms.QueueSender`	`getQueueSender()` returns an on-demand sender in a separate session
`void`	`onException(javax.jms.JMSException e)` catches JMSException of Connection asynchronously
`void`	`put(java.io.InputStream in)` continuously gets the JMS messages from the InputStream and puts them to the JMS queue.
`void`	`put(XQueue xq)` continuously gets the JMS messages from the XQueue and puts them to the JMS queue.
`void`	`qClose()` closes the queue
`void`	`qOpen()` opens the queue for the operation
`int`	`qReopen()` reopens the queue for the operation
`void`	`query(XQueue xq)` continuously gets the JMS messages from the XQueue and extracts message selector from messages.
`java.lang.String`	`reconnect()` reconnects to the JMS server for the operation or returns error text
`void`	`reply(XQueue xq)` continuously gets the JMS messages from the XQueue and sends them to their JMSReplyQ as the responses.
`void`	`request(XQueue xq, java.lang.String rq)` continuously gets the JMS messages from the XQueue and sends them to the JMS queue as requests and waits for responses from given queue.

- Field Detail
  - QC_QUEUE
```
static final int QC_QUEUE
```
    See Also:
    
    Constant Field Values
  - QC_TOPIC
```
static final int QC_TOPIC
```
    See Also:
    
    Constant Field Values
  - QC_STREAM
```
static final int QC_STREAM
```
    See Also:
    
    Constant Field Values
  - QC_XQ
```
static final int QC_XQ
```
    See Also:
    
    Constant Field Values
  - XA_CLIENT
```
static final int XA_CLIENT
```
    See Also:
    
    Constant Field Values
  - XA_COMMIT
```
static final int XA_COMMIT
```
    See Also:
    
    Constant Field Values
- Method Detail
  - browse
```
void browse(java.lang.Object out)
     throws java.io.IOException,
            javax.jms.JMSException
```
    browses the JMS messages from the JMS queue and puts them to the output, either a queue, a topic, a stream or an XQueue.
    
    Throws:
    
    java.io.IOException
    
    javax.jms.JMSException
  - query
```
void query(XQueue xq)
    throws TimeoutException,
           javax.jms.JMSException
```
    continuously gets the JMS messages from the XQueue and extracts message selector from messages. Then it queries the JMS queue for messages and packs them into the request message body as the response.
    
    Throws:
    
    TimeoutException
    
    javax.jms.JMSException
  - get
```
void get(java.lang.Object out)
  throws java.io.IOException,
         javax.jms.JMSException
```
    continuously gets the JMS messages from the JMS queue and puts them to the output, either a queue, a topic, a stream or an XQueue.
    
    Throws:
    
    java.io.IOException
    
    javax.jms.JMSException
  - request
```
void request(XQueue xq,
             java.lang.String rq)
      throws TimeoutException,
             javax.jms.JMSException
```
    continuously gets the JMS messages from the XQueue and sends them to the JMS queue as requests and waits for responses from given queue.
    
    Throws:
    
    TimeoutException
    
    javax.jms.JMSException
  - reply
```
void reply(XQueue xq)
    throws TimeoutException,
           javax.jms.JMSException
```
    continuously gets the JMS messages from the XQueue and sends them to their JMSReplyQ as the responses.
    
    Throws:
    
    TimeoutException
    
    javax.jms.JMSException
  - put
```
void put(java.io.InputStream in)
  throws java.io.IOException,
         javax.jms.JMSException
```
    continuously gets the JMS messages from the InputStream and puts them to the JMS queue.
    
    Throws:
    
    java.io.IOException
    
    javax.jms.JMSException
  - put
```
void put(XQueue xq)
  throws TimeoutException,
         javax.jms.JMSException
```
    continuously gets the JMS messages from the XQueue and puts them to the JMS queue.
    
    Throws:
    
    TimeoutException
    
    javax.jms.JMSException
  - createMessage
```
javax.jms.Message createMessage(int type)
                         throws javax.jms.JMSException
```
    returns a JMS Message with the initialized JMSSession
    
    Throws:
    
    javax.jms.JMSException
  - createQueue
```
javax.jms.Queue createQueue(java.lang.String name)
                     throws javax.jms.JMSException
```
    returns the queue created for the given name
    
    Throws:
    
    javax.jms.JMSException
  - createTemporaryQueue
```
javax.jms.Queue createTemporaryQueue()
                              throws javax.jms.JMSException
```
    returns the temporary queue created
    
    Throws:
    
    javax.jms.JMSException
  - getQueueBrowser
```
javax.jms.QueueBrowser getQueueBrowser()
```
    returns an on-demand browser in a separate session
  - getQueueReceiver
```
javax.jms.QueueReceiver getQueueReceiver()
```
    returns an on-demand receiver in a separate session
  - getQueueSender
```
javax.jms.QueueSender getQueueSender()
```
    returns an on-demand sender in a separate session
  - getOperation
```
java.lang.String getOperation()
```
    returns the string of the operation
  - qOpen
```
void qOpen()
    throws javax.jms.JMSException
```
    opens the queue for the operation
    
    Throws:
    
    javax.jms.JMSException
  - qClose
```
void qClose()
     throws javax.jms.JMSException
```
    closes the queue
    
    Throws:
    
    javax.jms.JMSException
  - qReopen
```
int qReopen()
```
    reopens the queue for the operation
  - reconnect
```
java.lang.String reconnect()
```
    reconnects to the JMS server for the operation or returns error text
  - onException
```
void onException(javax.jms.JMSException e)
```
    catches JMSException of Connection asynchronously
    
    Specified by:
    
    onException in interface javax.jms.ExceptionListener
  - close
```
void close()
```
    closes all opened resources

Interface QueueConnector

Field Summary

Method Summary

Field Detail

QC_QUEUE

QC_TOPIC

QC_STREAM

QC_XQ

XA_CLIENT

XA_COMMIT

Method Detail

browse

query

get

request

reply

put

put

createMessage

createQueue

createTemporaryQueue

getQueueBrowser

getQueueReceiver

getQueueSender

getOperation

qOpen

qClose

qReopen

reconnect

onException

close