jrun.jms.core.server.mipc
Class IpcJmsSessionConnection

java.lang.Object
  |
  +--jrun.jms.core.server.mipc.IpcJmsSessionConnection

All Implemented Interfaces:

NotifierIfc

public class IpcJmsSessionConnection

extends java.lang.Object

implements NotifierIfc

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: 2002/01/31 08:18:01 $

Author:

Jim Mourikis

See Also:

org.exolab.jms.server.mipc.IpcJmsReceiver, , org.exolab.jms.server.JmsServerConnectionManager, org.exolab.jms.server.JmsServerSession, org.exolab.core.ipc.NotifierIfc

Constructor Summary

IpcJmsSessionConnection()
Default constructor.

Method Summary

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, 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.
void	disconnection(java.lang.String id) The connection has been broken.
java.io.Serializable	notify(java.lang.Object ob, java.lang.String id) A new request has been received.
protected java.util.Vector	pack(java.lang.Boolean success, java.lang.Object ob) Pack all the data that is required by the server in a vector.
java.util.Vector	unsubscribe(JmsServerSession session, java.lang.String name) Unsubscribe a durable subscription

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IpcJmsSessionConnection

public IpcJmsSessionConnection()

Default constructor.

Method Detail

notify

public java.io.Serializable notify(java.lang.Object ob,
                                   java.lang.String id)

A new request has been received. Carry out the request, and pass back any relevent data.

Specified by:

notify in interface NotifierIfc

Parameters:

ob - The data received

id - The unique IPC id of the connection

The - unique identifier of this connection.

Returns:

Object Return any requested result. This must never be null.

disconnection

public void disconnection(java.lang.String id)

The connection has been broken. * @param The unique identifier of this connection.

Specified by:

disconnection in interface NotifierIfc

Following copied from interface: jrun.jms.core.kernel.ipc.NotifierIfc

Parameters:

The - unique identifier of this connection.

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,
                                            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.

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. Only used for http.

port - The port the client is listening on. Only used for http

url - The url for the clients web server. Only used for http

Returns:

Vector The result of the request.

unsubscribe

public java.util.Vector unsubscribe(JmsServerSession session,
                                    java.lang.String name)

Unsubscribe a durable subscription

Parameters:

session - the session the request is for

name - the name used to identify the subscription

Returns:

Vector the result of the request.

pack

protected java.util.Vector pack(java.lang.Boolean success,
                                java.lang.Object ob)

Pack all the data that is required by the server in a vector. Set the size of the vector to be exactly the right size for efficiency.

Parameters:

success - Boolean indicating success or failure of request.

ob - The Object being returned.

Returns:

Vector The vector containing all the data.