|
||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of JmsServerSession in org.exolab.jms.messagemgr |
Fields in org.exolab.jms.messagemgr declared as JmsServerSession | |
protected JmsServerSession |
ConsumerEndpoint._session
caches the session that created this endpoint |
Methods in org.exolab.jms.messagemgr that return JmsServerSession | |
JmsServerSession |
ConsumerEndpoint.getSession()
Return a reference to the session owning this endpoint |
Methods in org.exolab.jms.messagemgr with parameters of type JmsServerSession | |
ConsumerEndpoint |
ConsumerManager.createConsumerEndpoint(JmsServerSession session,
long clientId,
JmsDestination destination,
java.lang.String selector)
Create a transient consumer for the specified destination. |
DurableConsumerEndpoint |
ConsumerManager.createDurableConsumerEndpoint(JmsServerSession session,
JmsTopic topic,
java.lang.String name,
long clientId,
java.lang.String selector)
Create a durable consumer with the specified well-known name. |
ConsumerEndpoint |
ConsumerManager.createQueueBrowserEndpoint(JmsServerSession session,
long clientId,
JmsQueue queue,
java.lang.String selector)
Create a browser for the specified destination and the selector. |
Uses of JmsServerSession in org.exolab.jms.server |
Methods in org.exolab.jms.server that return JmsServerSession | |
JmsServerSession |
JmsServerConnection.createSession(int ackMode,
boolean transacted)
Create a sesion for the specified connection. |
JmsServerSession |
JmsServerConnection.getSession(java.lang.String sessionId)
Retrive the JmsServerSession with the given sessionId. |
Methods in org.exolab.jms.server with parameters of type JmsServerSession | |
void |
JmsServerConnection.deleteSession(JmsServerSession session)
Delete the specified session. |
Uses of JmsServerSession in org.exolab.jms.server.http |
Methods in org.exolab.jms.server.http with parameters of type JmsServerSession | |
protected java.util.Vector |
HttpJmsSessionConnection.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 |
HttpJmsSessionConnection.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 |
HttpJmsSessionConnection.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 java.util.Vector |
HttpJmsSessionConnection.close(JmsServerSession session,
org.exolab.core.mipc.MultiplexConnectionIfc connection)
A close request has been received. |
protected void |
HttpJmsSessionConnection.disconnect(JmsServerSession session)
A disconnection has been detected for this session, by the session sender, perform any neccessary cleanup, and deregister. |
Constructors in org.exolab.jms.server.http with parameters of type JmsServerSession | |
HttpJmsSessionSender(HttpJmsSessionConnection connection,
org.exolab.core.http.HttpClient client,
JmsServerSession session,
java.lang.String host,
java.lang.String port)
Create a connection to the client listener for sending JmsMessages. |
Uses of JmsServerSession in org.exolab.jms.server.mipc |
Methods in org.exolab.jms.server.mipc that return JmsServerSession | |
protected JmsServerSession |
IpcJmsSessionConnection.getSession(java.lang.String id,
java.util.Vector v)
A convenience routine to get the session. |
Methods in org.exolab.jms.server.mipc with parameters of type JmsServerSession | |
void |
IpcJmsServer.addConnection(JmsServerSession session,
org.exolab.core.mipc.MultiplexConnectionIfc connection)
Add a new connection for this client. |
void |
IpcJmsServer.removeConnection(JmsServerSession session,
org.exolab.core.mipc.MultiplexConnectionIfc connection)
Remove this sessions connection |
protected java.util.Vector |
IpcJmsSessionConnection.close(JmsServerSession session,
org.exolab.core.mipc.MultiplexConnectionIfc connection)
A close session request has been received. |
protected java.util.Vector |
IpcJmsSessionConnection.acknowledgeMessage(JmsServerSession session,
java.lang.Long clientId,
java.lang.String id)
Acknowledge a JmsMessage |
protected java.util.Vector |
IpcJmsSessionConnection.sendMessage(JmsServerSession session,
javax.jms.Message message)
A JmsMessage has been sent. |
protected java.util.Vector |
IpcJmsSessionConnection.sendMessages(JmsServerSession session,
java.util.Vector messages)
A collection of messages have been sent |
protected java.util.Vector |
IpcJmsSessionConnection.receiveMessage(JmsServerSession session,
java.lang.Long clientId,
java.lang.Long wait)
Receive a message from the provider |
protected java.util.Vector |
IpcJmsSessionConnection.receiveMessages(JmsServerSession session,
java.lang.Long clientId,
java.lang.Integer count)
Receive upto count messages from the endpoint |
protected java.util.Vector |
IpcJmsSessionConnection.createQueue(JmsServerSession session,
JmsQueue queue)
Create a new Queue. |
protected java.util.Vector |
IpcJmsSessionConnection.createTopic(JmsServerSession session,
JmsTopic topic)
Create a new topic |
protected java.util.Vector |
IpcJmsSessionConnection.createReceiver(JmsServerSession session,
JmsQueue queue,
java.lang.Long consumerId,
java.lang.String selector,
org.exolab.core.mipc.MultiplexConnectionIfc connection,
java.lang.String host,
java.lang.String port,
java.lang.String url)
Create a new receiver |
protected java.util.Vector |
IpcJmsSessionConnection.createSender(JmsServerSession session,
JmsQueue queue)
Create a new sender for the given queue. |
protected java.util.Vector |
IpcJmsSessionConnection.createBrowser(JmsServerSession session,
JmsQueue queue,
java.lang.Long clientId,
java.lang.String selector,
org.exolab.core.mipc.MultiplexConnectionIfc connection,
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 |
IpcJmsSessionConnection.deleteReceiver(JmsServerSession session,
java.lang.Long clientId)
Delete the receiver for this queue. |
protected java.util.Vector |
IpcJmsSessionConnection.deleteSender(JmsServerSession session,
java.lang.Long clientId)
Delete the sender for this queue. |
protected java.util.Vector |
IpcJmsSessionConnection.deleteBrowser(JmsServerSession session,
java.lang.Long clientId)
Delete the queue browser for the specified queue. |
protected java.util.Vector |
IpcJmsSessionConnection.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 connection,
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 java.util.Vector |
IpcJmsSessionConnection.createPublisher(JmsServerSession session,
JmsTopic topic)
Create a new publisher for the given topic. |
protected java.util.Vector |
IpcJmsSessionConnection.deleteSubscriber(JmsServerSession session,
java.lang.Long clientId)
Delete a subscriber for the given topic |
protected java.util.Vector |
IpcJmsSessionConnection.deletePublisher(JmsServerSession session,
JmsTopic topic)
Delete a publisher for the given topic. |
java.util.Vector |
IpcJmsSessionConnection.unsubscribe(JmsServerSession session,
java.lang.String name)
Unsubscribe a durable subscription |
protected java.util.Vector |
IpcJmsSessionConnection.stopMessageDelivery(JmsServerSession session)
Stop message delivery for this session. |
protected java.util.Vector |
IpcJmsSessionConnection.enableAsynchronousDelivery(JmsServerSession session,
java.lang.Long clientId,
java.lang.String id,
java.lang.Boolean enable)
Enable or disable asynchronous message delivery. |
protected java.util.Vector |
IpcJmsSessionConnection.startMessageDelivery(JmsServerSession session)
Start message delivery for this session. |
protected java.util.Vector |
IpcJmsSessionConnection.recover(JmsServerSession session)
recover the session |
protected java.util.Vector |
IpcJmsSessionConnection.commit(JmsServerSession session)
commit the session |
protected java.util.Vector |
IpcJmsSessionConnection.rollback(JmsServerSession session)
rollback the session |
protected java.util.Vector |
IpcJmsSessionConnection.XACommit(JmsServerSession session,
javax.transaction.xa.Xid xid,
java.lang.Boolean onePhase)
Commits an XA transaction that is in progress. |
protected java.util.Vector |
IpcJmsSessionConnection.XAEnd(JmsServerSession session,
javax.transaction.xa.Xid xid,
java.lang.Integer flags)
Ends the work performed on behalf of a transaction branch. |
protected java.util.Vector |
IpcJmsSessionConnection.XAForget(JmsServerSession session,
javax.transaction.xa.Xid xid)
Tell the resource manager to forget about a heuristically completed transaction branch. |
protected java.util.Vector |
IpcJmsSessionConnection.XAGetTransactionTimeout(JmsServerSession session)
Return the transaction timeout for this instance of the resource manager. |
protected java.util.Vector |
IpcJmsSessionConnection.XAPrepare(JmsServerSession session,
javax.transaction.xa.Xid xid)
Ask the resource manager to prepare for a transaction commit of the transaction specified in xid |
java.util.Vector |
IpcJmsSessionConnection.XARecover(JmsServerSession session,
java.lang.Integer flag)
Obtain a list of prepared transaction branches from a resource manager. |
protected java.util.Vector |
IpcJmsSessionConnection.XARollback(JmsServerSession session,
javax.transaction.xa.Xid xid)
Inform the resource manager to roll back work done on behalf of a transaction branch |
protected java.util.Vector |
IpcJmsSessionConnection.XASetTransactionTimeout(JmsServerSession session,
java.lang.Integer seconds)
Set the current transaction timeout value for this XAResource instance. |
protected java.util.Vector |
IpcJmsSessionConnection.XAStart(JmsServerSession session,
javax.transaction.xa.Xid xid,
java.lang.Integer flags)
Start work on behalf of a transaction branch specified in xid If TMJOIN is specified, the start is for joining a transaction previously seen by the resource manager |
protected java.util.Vector |
IpcJmsSessionConnection.XAGetResourceManagerId(JmsServerSession session)
Return the identity of the resource manager. |
void |
IpcJmsSessionList.add(JmsServerSession session)
Add a new session sender for the client. |
boolean |
IpcJmsSessionList.remove(JmsServerSession session)
Remove a sesson notifier. |
Constructors in org.exolab.jms.server.mipc with parameters of type JmsServerSession | |
IpcJmsSessionSender(org.exolab.core.mipc.ObjectChannel client,
JmsServerSession session)
Create a connection to the client listener for sending JmsMessages. |
Uses of JmsServerSession in org.exolab.jms.server.rmi |
Constructors in org.exolab.jms.server.rmi with parameters of type JmsServerSession | |
RmiJmsServerSession(JmsServerSession session)
Instantiate an instance of this class given a JmsServerSession. |
|
||||||||
PREV NEXT | FRAMES NO FRAMES |