org.exolab.jms.server.http
Class HttpJmsSessionConnection

java.lang.Object
  |
  +--org.exolab.jms.server.mipc.IpcJmsSessionConnection
        |
        +--org.exolab.jms.server.http.HttpJmsSessionConnection

All Implemented Interfaces:

org.exolab.core.ipc.NotifierIfc

public class HttpJmsSessionConnection

extends IpcJmsSessionConnection

This is the server side receiver for JmsSession requests. All requests are unpacked and passed on to the appropriate JmsServerSession object.

Version:

$Revision: 1.14 $ $Date: 2003/08/25 03:38:14 $

Author:

Jim Mourikis

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

HttpJmsSessionConnection

public HttpJmsSessionConnection(IpcJmsServer server)

Construct a new HttpJmsSessionConnection

Parameters:

server - the server instance

Method Detail

createReceiver

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

Overrides:

createReceiver in class IpcJmsSessionConnection

Parameters:

session - The session the request is for.

queue - The queue to create the reciver for

consumerName - The unique name of this consumer, only valid for persitent messages

selector - The selector to filter messages. This may be null.

connection - The MultiplexConnection to the machine the consumer is on

host - The host the client is running on.

port - The port the client is listening on.

url - The url for the clients web server.

Returns:

Vector The result of the request.

createBrowser

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.

Overrides:

createBrowser in class IpcJmsSessionConnection

Parameters:

session - session that the request is for

queue - queue to browse

clientId - the client identity

selector - message selector. May be null

connection - the connection to the remote machine

host - The host the client is running on.

port - The port the client is listening on.

url - The url for the clients web server.

Returns:

Vector result of the request

createSubscriber

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.

Overrides:

createSubscriber in class IpcJmsSessionConnection

Parameters:

session - The session the request is for.

topic - The topic the subscriber is subscribing on

name - The unique name of this subscriber, only valid for persitent messages

selector - The selector to filter messages. This may be null.

connection - The MultiplexConnection to the machine the consumer is on

host - The host the client is running on.

port - The port the client is listening on.

url - The url for the clients web server.

Returns:

Vector The result of the request.

close

protected java.util.Vector close(JmsServerSession session,
                                 org.exolab.core.mipc.MultiplexConnectionIfc connection)

A close request has been received.

Overrides:

close in class IpcJmsSessionConnection

Parameters:

session - the session to close

connection - the connection associated with the session

Returns:

the result of the request.

disconnect

protected void disconnect(JmsServerSession session)

A disconnection has been detected for this session, by the session sender, perform any neccessary cleanup, and deregister.