|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.exolab.jms.server.mipc.IpcJmsSessionConnection
org.exolab.jms.server.http.HttpJmsSessionConnection
public class HttpJmsSessionConnection
This is the server side receiver for JmsSession requests. All requests are unpacked and passed on to the appropriate JmsServerSession object.
Constructor Summary | |
---|---|
HttpJmsSessionConnection(IpcJmsServer server)
Construct a new HttpJmsSessionConnection |
Method Summary | |
---|---|
protected java.util.Vector |
close(JmsServerSession session,
org.exolab.core.mipc.MultiplexConnectionIfc connection)
A close request has been received. |
protected java.util.Vector |
createBrowser(JmsServerSession session,
JmsQueue queue,
java.lang.Long clientId,
java.lang.String selector,
org.exolab.core.mipc.MultiplexConnectionIfc not_used,
java.lang.String host,
java.lang.String port,
java.lang.String url)
Create a new queue browser for the specified session and queue. |
protected java.util.Vector |
createReceiver(JmsServerSession session,
JmsQueue queue,
java.lang.Long consumerId,
java.lang.String selector,
org.exolab.core.mipc.MultiplexConnectionIfc not_used,
java.lang.String host,
java.lang.String port,
java.lang.String url)
Create a new receiver |
protected java.util.Vector |
createSubscriber(JmsServerSession session,
JmsTopic topic,
java.lang.String name,
java.lang.Long clientId,
java.lang.String selector,
java.lang.Boolean noLocal,
org.exolab.core.mipc.MultiplexConnectionIfc not_used,
java.lang.String host,
java.lang.String port,
java.lang.String url)
Create a new subscriber, and connect back to the client through the MultiplexConnection. |
protected void |
disconnect(JmsServerSession session)
A disconnection has been detected for this session, by the session sender, perform any neccessary cleanup, and deregister. |
Methods inherited from class org.exolab.jms.server.mipc.IpcJmsSessionConnection |
---|
acknowledgeMessage, commit, createPublisher, createQueue, createSender, createTopic, deleteBrowser, deletePublisher, deleteReceiver, deleteSender, deleteSubscriber, disconnection, enableAsynchronousDelivery, getConnection, getSession, notify, pack, receiveMessage, receiveMessages, recover, rollback, sendMessage, sendMessages, startMessageDelivery, stopMessageDelivery, unsubscribe, XACommit, XAEnd, XAForget, XAGetResourceManagerId, XAGetTransactionTimeout, XAPrepare, XARecover, XARollback, XASetTransactionTimeout, XAStart |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public HttpJmsSessionConnection(IpcJmsServer server)
HttpJmsSessionConnection
server
- the server instanceMethod Detail |
---|
protected java.util.Vector createReceiver(JmsServerSession session, JmsQueue queue, java.lang.Long consumerId, java.lang.String selector, org.exolab.core.mipc.MultiplexConnectionIfc not_used, java.lang.String host, java.lang.String port, java.lang.String url)
createReceiver
in class IpcJmsSessionConnection
session
- The session the request is for.queue
- The queue to create the reciver forconsumerName
- The unique name of this consumer,
only valid for persitent messagesselector
- The selector to filter messages. This may be null.connection
- The MultiplexConnection to the machine the consumer is onhost
- The host the client is running on.port
- The port the client is listening on.url
- The url for the clients web server.
protected java.util.Vector createBrowser(JmsServerSession session, JmsQueue queue, java.lang.Long clientId, java.lang.String selector, org.exolab.core.mipc.MultiplexConnectionIfc not_used, java.lang.String host, java.lang.String port, java.lang.String url)
createBrowser
in class IpcJmsSessionConnection
session
- session that the request is forqueue
- queue to browseclientId
- the client identityselector
- message selector. May be nullconnection
- the connection to the remote machinehost
- The host the client is running on.port
- The port the client is listening on.url
- The url for the clients web server.
protected java.util.Vector createSubscriber(JmsServerSession session, JmsTopic topic, java.lang.String name, java.lang.Long clientId, java.lang.String selector, java.lang.Boolean noLocal, org.exolab.core.mipc.MultiplexConnectionIfc not_used, java.lang.String host, java.lang.String port, java.lang.String url)
createSubscriber
in class IpcJmsSessionConnection
session
- The session the request is for.topic
- The topic the subscriber is subscribing onname
- The unique name of this subscriber,
only valid for persitent messagesselector
- The selector to filter messages. This may be null.connection
- The MultiplexConnection to the machine the consumer is onhost
- The host the client is running on.port
- The port the client is listening on.url
- The url for the clients web server.
protected java.util.Vector close(JmsServerSession session, org.exolab.core.mipc.MultiplexConnectionIfc connection)
close
in class IpcJmsSessionConnection
session
- the session to closeconnection
- the connection associated with the session
protected void disconnect(JmsServerSession session)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |