|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.jms.server.endpoint.ServerSessionEndpoint
Concrete implementation of SessionEndpoint.
Constructor Summary | |
protected |
ServerSessionEndpoint(int sessionID,
ServerConnectionEndpoint connectionEndpoint)
|
Method Summary | |
void |
acknowledge(AckInfo ackInfo)
Acknowledge a message - used for auto acknowledge |
void |
acknowledgeBatch(java.util.List ackInfos)
Acknowledge a batch of messages - used with client acknowledge or dups_ok acknowledge |
protected void |
acknowledgeInternal(AckInfo ackInfo)
|
void |
addTemporaryDestination(JBossDestination dest)
Add a temporary destination. |
void |
cancelDeliveries(java.util.List ackInfos)
Cancel some deliveries. |
void |
close()
Close the instance |
void |
closing()
Tell the instance to prepare to close |
BrowserDelegate |
createBrowserDelegate(JBossDestination jmsDestination,
java.lang.String messageSelector)
|
ConsumerDelegate |
createConsumerDelegate(JBossDestination jmsDestination,
java.lang.String selector,
boolean noLocal,
java.lang.String subscriptionName,
boolean isCC)
|
JBossQueue |
createQueue(java.lang.String name)
Creates a queue identity given a Queue name. |
JBossTopic |
createTopic(java.lang.String name)
Creates a topic identity given a Queue name. |
void |
deleteTemporaryDestination(JBossDestination dest)
Delete a temporary destination |
protected ServerBrowserEndpoint |
getBrowserDelegate(int browserID)
|
ServerConnectionEndpoint |
getConnectionEndpoint()
|
protected ServerConsumerEndpoint |
getConsumerEndpoint(int consumerID)
|
boolean |
isClosed()
|
protected ServerBrowserEndpoint |
putBrowserDelegate(int browserID,
ServerBrowserEndpoint sbd)
|
protected ServerConsumerEndpoint |
putConsumerEndpoint(int consumerID,
ServerConsumerEndpoint d)
|
protected ServerBrowserEndpoint |
removeBrowserDelegate(int browserID)
|
protected ServerConsumerEndpoint |
removeConsumerEndpoint(int consumerID)
|
void |
send(JBossMessage message)
Send a message |
protected void |
setStarted(boolean s)
Starts this session's Consumers |
java.lang.String |
toString()
|
void |
unsubscribe(java.lang.String subscriptionName)
Unsubscribe the client from the durable subscription specified by subscriptionName |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
protected ServerSessionEndpoint(int sessionID, ServerConnectionEndpoint connectionEndpoint) throws java.lang.Exception
Method Detail |
public ConsumerDelegate createConsumerDelegate(JBossDestination jmsDestination, java.lang.String selector, boolean noLocal, java.lang.String subscriptionName, boolean isCC) throws JMSException
createConsumerDelegate
in interface SessionEndpoint
JMSException
public BrowserDelegate createBrowserDelegate(JBossDestination jmsDestination, java.lang.String messageSelector) throws JMSException
createBrowserDelegate
in interface SessionEndpoint
JMSException
public JBossQueue createQueue(java.lang.String name) throws JMSException
SessionEndpoint
createQueue
in interface SessionEndpoint
JMSException
public JBossTopic createTopic(java.lang.String name) throws JMSException
SessionEndpoint
createTopic
in interface SessionEndpoint
JMSException
public void close() throws JMSException
Closeable
close
in interface Closeable
JMSException
public void closing() throws JMSException
Closeable
closing
in interface Closeable
JMSException
public boolean isClosed()
isClosed
in interface Closeable
public void send(JBossMessage message) throws JMSException
SessionEndpoint
send
in interface SessionEndpoint
message
- The message to send
JMSException
public void acknowledgeBatch(java.util.List ackInfos) throws JMSException
SessionEndpoint
acknowledgeBatch
in interface SessionEndpoint
ackInfos
-
JMSException
public void acknowledge(AckInfo ackInfo) throws JMSException
SessionEndpoint
acknowledge
in interface SessionEndpoint
ackInfo
-
JMSException
public void cancelDeliveries(java.util.List ackInfos) throws JMSException
SessionEndpoint
cancelDeliveries
in interface SessionEndpoint
ackInfos
-
JMSException
public void addTemporaryDestination(JBossDestination dest) throws JMSException
SessionEndpoint
addTemporaryDestination
in interface SessionEndpoint
JMSException
public void deleteTemporaryDestination(JBossDestination dest) throws JMSException
SessionEndpoint
deleteTemporaryDestination
in interface SessionEndpoint
JMSException
public void unsubscribe(java.lang.String subscriptionName) throws JMSException
SessionEndpoint
unsubscribe
in interface SessionEndpoint
subscriptionName
- the Name of the durable subscription to unsubscribe from
JMSException
public ServerConnectionEndpoint getConnectionEndpoint()
public java.lang.String toString()
protected void acknowledgeInternal(AckInfo ackInfo) throws java.lang.Throwable
java.lang.Throwable
protected ServerConsumerEndpoint putConsumerEndpoint(int consumerID, ServerConsumerEndpoint d)
protected ServerConsumerEndpoint getConsumerEndpoint(int consumerID)
protected ServerConsumerEndpoint removeConsumerEndpoint(int consumerID)
protected ServerBrowserEndpoint putBrowserDelegate(int browserID, ServerBrowserEndpoint sbd)
protected ServerBrowserEndpoint getBrowserDelegate(int browserID)
protected ServerBrowserEndpoint removeBrowserDelegate(int browserID)
protected void setStarted(boolean s) throws java.lang.Throwable
java.lang.Throwable
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |