|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.j_spaces.jms.GSTopicConnectionImpl
public class GSTopicConnectionImpl
Implements the javax.jms.TopicConnection
interface.
GigaSpaces implementation of the JMS TopicConnection Inerface.
It also extends the GSConnectionImpl and overwrites most of its methods. - It holds the list of the sessions that attached to this conn. - It returns a LocalTransaction instance - It starts, stops and closes the Connection
Constructor Summary | |
---|---|
GSTopicConnectionImpl(GSConnectionFactoryImpl _connFacParent)
Constructor: Calling super com.j_spaces.jms.GSConnectionImpl. |
Method Summary | |
---|---|
void |
close()
API method for closing the connection; even if the connection appears to be broken, closes the sessions. |
ConnectionConsumer |
createConnectionConsumer(Destination destination,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
|
ConnectionConsumer |
createConnectionConsumer(Queue queue,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
|
ConnectionConsumer |
createConnectionConsumer(Topic topic,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
|
ConnectionConsumer |
createDurableConnectionConsumer(Topic topic,
String subscriptionName,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
|
QueueSession |
createQueueSession(boolean transacted,
int acknowledgeMode)
|
Session |
createSession(boolean transacted,
int acknowledgeMode)
Use the extended methods, from GSTopicConnectionImpl for Topic and from GSQueueConnectionImpl for Queue. |
TopicSession |
createTopicSession(boolean transacted,
int acknowledgeMode)
|
String |
getClientID()
The connection client ID contains the space name together with the Destination name, "space name_destination name" e.g. |
int |
getCompressionMinSize()
|
ExceptionListener |
getExceptionListener()
|
ConnectionMetaData |
getMetaData()
|
Transaction |
getTransaction(boolean localTransaction,
long leaseTime)
create a new local transaction instance and use it in case of a transacted JMS session. |
void |
setClientID(String clientID)
The connection client ID contains the random connection Key + hostname + space name + destination name "space name_destination name" e.g. |
void |
setExceptionListener(ExceptionListener listener)
|
void |
start()
Overwrite of the API method for starting the Topic connection. |
void |
stop()
Overwrite of the API method for stoping the Topic connection. |
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public GSTopicConnectionImpl(GSConnectionFactoryImpl _connFacParent) throws JMSException
_connFacParent
- connection factory
JMSException
Method Detail |
---|
public Session createSession(boolean transacted, int acknowledgeMode) throws JMSException
createSession
in interface Connection
JMSException
Connection.createSession(boolean, int)
public String getClientID() throws JMSException
getClientID
in interface Connection
JMSException
Connection.getClientID()
public void setClientID(String clientID) throws JMSException
setClientID
in interface Connection
clientID
-
IllegalStateException
JMSException
Connection.setClientID(java.lang.String)
public ConnectionMetaData getMetaData() throws JMSException
getMetaData
in interface Connection
JMSException
Connection.getMetaData()
,
GSConnectionMetaDataImpl
public ExceptionListener getExceptionListener() throws JMSException
getExceptionListener
in interface Connection
JMSException
Connection.getExceptionListener()
public void setExceptionListener(ExceptionListener listener) throws JMSException
setExceptionListener
in interface Connection
JMSException
Connection.setExceptionListener(javax.jms.ExceptionListener)
public void start() throws JMSException
start
in interface Connection
IllegalStateException
- If the connection is closed or broken.
JMSException
public void stop() throws JMSException
stop
in interface Connection
IllegalStateException
- If the connection is closed or broken.
JMSException
Connection.stop()
public void close() throws JMSException
close
in interface Connection
JMSException
- Actually never thrown.public ConnectionConsumer createConnectionConsumer(Destination destination, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
createConnectionConsumer
in interface Connection
JMSException
Connection.createConnectionConsumer(javax.jms.Destination,
java.lang.String, javax.jms.ServerSessionPool, int)
public ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
createDurableConnectionConsumer
in interface Connection
createDurableConnectionConsumer
in interface TopicConnection
JMSException
Connection.createDurableConnectionConsumer(javax.jms.Topic,
java.lang.String, java.lang.String, javax.jms.ServerSessionPool,
int)
public Transaction getTransaction(boolean localTransaction, long leaseTime) throws com.j_spaces.jms.TransactionCreateException
leaseTime
-
JMSException
com.j_spaces.jms.TransactionCreateException
public String toString()
toString
in class Object
public int getCompressionMinSize()
public ConnectionConsumer createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
createConnectionConsumer
in interface QueueConnection
JMSException
QueueConnection.createConnectionConsumer(Queue, String, ServerSessionPool, int)
public QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws JMSException
createQueueSession
in interface QueueConnection
JMSException
QueueConnection.createQueueSession(boolean, int)
public ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
createConnectionConsumer
in interface TopicConnection
JMSException
TopicConnection.createConnectionConsumer(Topic, String, ServerSessionPool, int)
public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException
createTopicSession
in interface TopicConnection
JMSException
TopicConnection.createTopicSession(boolean, int)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |