org.qbroker.jms

Interface TopicConnector

All Superinterfaces:

javax.jms.ExceptionListener

All Known Implementing Classes:

JMSTConnector, TConnector, TConnector

public interface TopicConnector
extends javax.jms.ExceptionListener

TopicConnector is an Interface for JMS Topic and its connections

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	TC_QUEUE
static int	TC_STREAM
static int	TC_TOPIC
static int	TC_XQ
static int	XA_CLIENT
static int	XA_COMMIT

Method Summary

Modifier and Type	Method and Description
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
java.lang.String	getOperation() returns the string of the operation
javax.jms.TopicPublisher	getTopicPublisher() returns an on-demand publisher in a separate session
javax.jms.TopicSubscriber	getTopicSubscriber() returns an on-demand subscriber in a separate session
void	onException(javax.jms.JMSException e) catches JMSException of Connection asynchronously
void	pub(java.io.InputStream in) continuously gets the JMS messages from the InputStream and publishes them with the JMS topic.
void	pub(XQueue xq) continuously gets the JMS messages from the XQueue and publishes them with the JMS topic.
java.lang.String	reconnect() reconnects to the JMS server for the operation or returns error text
void	sub(java.lang.Object out) continuously subscribes the JMS messages from the JMS topic and puts them to the output, either a queue, a topic, a stream or an XQueue.
void	tClose() closes the topic
void	tOpen() opens the topic for the operation
int	tReopen() reopens the topic for the operation

Field Detail

TC_QUEUE

static final int TC_QUEUE

See Also:

Constant Field Values

TC_TOPIC

static final int TC_TOPIC

See Also:

Constant Field Values

TC_STREAM

static final int TC_STREAM

See Also:

Constant Field Values

TC_XQ

static final int TC_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

sub

void sub(java.lang.Object out)
  throws java.io.IOException,
         javax.jms.JMSException

continuously subscribes the JMS messages from the JMS topic and puts them to the output, either a queue, a topic, a stream or an XQueue.

Throws:

java.io.IOException

javax.jms.JMSException

pub

void pub(XQueue xq)
  throws TimeoutException,
         javax.jms.JMSException

continuously gets the JMS messages from the XQueue and publishes them with the JMS topic.

Throws:

TimeoutException

javax.jms.JMSException

pub

void pub(java.io.InputStream in)
  throws java.io.IOException,
         javax.jms.JMSException

continuously gets the JMS messages from the InputStream and publishes them with the JMS topic.

Throws:

java.io.IOException

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

getTopicSubscriber

javax.jms.TopicSubscriber getTopicSubscriber()

returns an on-demand subscriber in a separate session

getTopicPublisher

javax.jms.TopicPublisher getTopicPublisher()

returns an on-demand publisher in a separate session

getOperation

java.lang.String getOperation()

returns the string of the operation

tOpen

void tOpen()
    throws javax.jms.JMSException

opens the topic for the operation

Throws:

javax.jms.JMSException

tClose

void tClose()
     throws javax.jms.JMSException

closes the topic

Throws:

javax.jms.JMSException

tReopen

int tReopen()

reopens the topic 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