org.jboss.mq.il.jvm
Class JVMServerIL

java.lang.Object
  org.jboss.mq.il.jvm.JVMServerIL

All Implemented Interfaces:

ServerIL, Recoverable

public class JVMServerIL
extends Object
implements ServerIL, Recoverable

The JVM implementation of the ServerIL object

Version:

$Revision: 57198 $

Author:

Hiram Chirino (Cojonudo14@hotmail.com), Norbert Lataille (Norbert.Lataille@m4x.org), Peter Antman, Adrian Brock

Constructor Summary

JVMServerIL(Invoker s)
Constructor for the JVMServerIL object

Method Summary

void	acknowledge(ConnectionToken dc, AcknowledgementRequest item) #Description of the Method
void	addMessage(ConnectionToken dc, SpyMessage val) Adds a message to the destination specifyed in the message.
String	authenticate(String userName, String password) Authenticate the user.
SpyMessage[]	browse(ConnectionToken dc, javax.jms.Destination dest, String selector) #Description of the Method
void	checkID(String ID) Check if clientID is a valid ID.
String	checkUser(String userName, String password) Get a clientID for a given user/password.
ServerIL	cloneServerIL() #Description of the Method
void	connectionClosing(ConnectionToken dc) The client is closing the connection.
javax.jms.Queue	createQueue(ConnectionToken dc, String dest) #Description of the Method
javax.jms.Topic	createTopic(ConnectionToken dc, String dest) #Description of the Method
void	deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest) #Description of the Method
void	destroySubscription(ConnectionToken dc, DurableSubscriptionID id) Unsubscribe from a durable subscription.
String	getID() Get a clientID from the server.
javax.jms.TemporaryQueue	getTemporaryQueue(ConnectionToken dc) Gets the TemporaryQueue attribute of the ServerIL object
javax.jms.TemporaryTopic	getTemporaryTopic(ConnectionToken dc) Gets the TemporaryTopic attribute of the ServerIL object
void	ping(ConnectionToken dc, long clientTime) Ping the server.
SpyMessage	receive(ConnectionToken dc, int subscriberId, long wait) Get a message synchronously.
Xid[]	recover(ConnectionToken dc, int flags) Recover
void	setConnectionToken(ConnectionToken newConnectionToken)
void	setEnabled(ConnectionToken dc, boolean enabled) Sets the Enabled attribute of the ServerIL object
void	subscribe(ConnectionToken dc, Subscription s)
void	transact(ConnectionToken dc, TransactionRequest t) #Description of the Method
void	unsubscribe(ConnectionToken dc, int subscriptionId) Remove a consumer.

Methods inherited from class java.lang.Object

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

Constructor Detail

JVMServerIL

public JVMServerIL(Invoker s)

Constructor for the JVMServerIL object

Parameters:

s - Description of Parameter

Method Detail

setConnectionToken

public void setConnectionToken(ConnectionToken newConnectionToken)

Specified by:

setConnectionToken in interface ServerIL

Parameters:

newConnectionToken - org.jboss.mq.ConnectionToken

setEnabled

public void setEnabled(ConnectionToken dc,
                       boolean enabled)
                throws Exception

Description copied from interface: ServerIL

Sets the Enabled attribute of the ServerIL object

Specified by:

setEnabled in interface ServerIL

Parameters:

dc - The new Enabled value

enabled - The new Enabled value

Throws:

Exception - Description of Exception

getID

public String getID()
             throws javax.jms.JMSException

Description copied from interface: ServerIL

Get a clientID from the server. It is up to the server side components to update the ConectionToken if this method returns normaly.

Specified by:

getID in interface ServerIL

Returns:

an internally generated clientID.

Throws:

javax.jms.JMSException

getTemporaryQueue

public javax.jms.TemporaryQueue getTemporaryQueue(ConnectionToken dc)
                                           throws javax.jms.JMSException

Description copied from interface: ServerIL

Gets the TemporaryQueue attribute of the ServerIL object

Specified by:

getTemporaryQueue in interface ServerIL

Parameters:

dc - Description of Parameter

Returns:

The TemporaryQueue value

Throws:

javax.jms.JMSException

getTemporaryTopic

public javax.jms.TemporaryTopic getTemporaryTopic(ConnectionToken dc)
                                           throws javax.jms.JMSException

Description copied from interface: ServerIL

Gets the TemporaryTopic attribute of the ServerIL object

Specified by:

getTemporaryTopic in interface ServerIL

Parameters:

dc - Description of Parameter

Returns:

The TemporaryTopic value

Throws:

javax.jms.JMSException

cloneServerIL

public ServerIL cloneServerIL()

Description copied from interface: ServerIL

#Description of the Method

Specified by:

cloneServerIL in interface ServerIL

Returns:

Description of the Returned Value

addMessage

public void addMessage(ConnectionToken dc,
                       SpyMessage val)
                throws javax.jms.JMSException

Description copied from interface: ServerIL

Adds a message to the destination specifyed in the message.

Specified by:

addMessage in interface ServerIL

Parameters:

dc - The feature to be added to the Message attribute

val - The feature to be added to the Message attribute

Throws:

javax.jms.JMSException

createTopic

public javax.jms.Topic createTopic(ConnectionToken dc,
                                   String dest)
                            throws javax.jms.JMSException

Description copied from interface: ServerIL

#Description of the Method

Specified by:

createTopic in interface ServerIL

Parameters:

dc - Description of Parameter

dest - Description of Parameter

Returns:

Description of the Returned Value

Throws:

javax.jms.JMSException

createQueue

public javax.jms.Queue createQueue(ConnectionToken dc,
                                   String dest)
                            throws javax.jms.JMSException

Description copied from interface: ServerIL

#Description of the Method

Specified by:

createQueue in interface ServerIL

Parameters:

dc - Description of Parameter

dest - Description of Parameter

Returns:

Description of the Returned Value

Throws:

javax.jms.JMSException

deleteTemporaryDestination

public void deleteTemporaryDestination(ConnectionToken dc,
                                       SpyDestination dest)
                                throws javax.jms.JMSException

Description copied from interface: ServerIL

#Description of the Method

Specified by:

deleteTemporaryDestination in interface ServerIL

Parameters:

dc - Description of Parameter

dest - Description of Parameter

Throws:

javax.jms.JMSException

checkID

public void checkID(String ID)
             throws javax.jms.JMSException

Description copied from interface: ServerIL

Check if clientID is a valid ID. This method should be called when the client tries to set its own clientID. It is up to the server side components to update the ConectionToken if this method returns normaly.

Specified by:

checkID in interface ServerIL

Parameters:

ID - a clientID set by the client.

Throws:

javax.jms.JMSException

connectionClosing

public void connectionClosing(ConnectionToken dc)
                       throws javax.jms.JMSException

Description copied from interface: ServerIL

The client is closing the connection.

Specified by:

connectionClosing in interface ServerIL

Parameters:

dc - Description of Parameter

Throws:

javax.jms.JMSException

acknowledge

public void acknowledge(ConnectionToken dc,
                        AcknowledgementRequest item)
                 throws Exception

Description copied from interface: ServerIL

#Description of the Method

Specified by:

acknowledge in interface ServerIL

Parameters:

dc - Description of Parameter

item - Description of Parameter

Throws:

Exception - Description of Exception

browse

public SpyMessage[] browse(ConnectionToken dc,
                           javax.jms.Destination dest,
                           String selector)
                    throws Exception

Description copied from interface: ServerIL

#Description of the Method

Specified by:

browse in interface ServerIL

Parameters:

dc - Description of Parameter

dest - Description of Parameter

selector - Description of Parameter

Returns:

Description of the Returned Value

Throws:

Exception - Description of Exception

receive

public SpyMessage receive(ConnectionToken dc,
                          int subscriberId,
                          long wait)
                   throws Exception

Description copied from interface: ServerIL

Get a message synchronously.

Specified by:

receive in interface ServerIL

Parameters:

dc - Description of Parameter

subscriberId - Description of Parameter

wait - Description of Parameter

Returns:

Description of the Returned Value

Throws:

Exception - Description of Exception

unsubscribe

public void unsubscribe(ConnectionToken dc,
                        int subscriptionId)
                 throws Exception

Description copied from interface: ServerIL

Remove a consumer. Is NOT the same as the topic session unsubscribe.

Specified by:

unsubscribe in interface ServerIL

Parameters:

dc - Description of Parameter

subscriptionId - Description of Parameter

Throws:

Exception - Description of Exception

destroySubscription

public void destroySubscription(ConnectionToken dc,
                                DurableSubscriptionID id)
                         throws Exception

Description copied from interface: ServerIL

Unsubscribe from a durable subscription.

Specified by:

destroySubscription in interface ServerIL

id - Description of Parameter

Throws:

Exception - Description of Exception

checkUser

public String checkUser(String userName,
                        String password)
                 throws javax.jms.JMSException

Description copied from interface: ServerIL

Get a clientID for a given user/password. May also be used for autentication if StateManager is used as authenticator.

Specified by:

checkUser in interface ServerIL

Parameters:

userName - a valid user name that the StateManager knows about.

password - a password

Returns:

a preconfigured clientID or null.

Throws:

javax.jms.JMSException

authenticate

public String authenticate(String userName,
                           String password)
                    throws javax.jms.JMSException

Description copied from interface: ServerIL

Authenticate the user. If using a securityManager the user will be autenticated by that.

Specified by:

authenticate in interface ServerIL

Parameters:

userName - a username.

password - a password.

Returns:

a sessionid, valid only for the life of this connection.

Throws:

javax.jms.JMSException

subscribe

public void subscribe(ConnectionToken dc,
                      Subscription s)
               throws Exception

Specified by:

subscribe in interface ServerIL

Parameters:

dc - org.jboss.mq.ConnectionToken

s - org.jboss.mq.Subscription

Throws:

Exception - The exception description.

transact

public void transact(ConnectionToken dc,
                     TransactionRequest t)
              throws javax.jms.JMSException

Description copied from interface: ServerIL

#Description of the Method

Specified by:

transact in interface ServerIL

Parameters:

dc - Description of Parameter

t - Description of Parameter

Throws:

javax.jms.JMSException

ping

public void ping(ConnectionToken dc,
                 long clientTime)
          throws javax.jms.JMSException

Description copied from interface: ServerIL

Ping the server.

Specified by:

ping in interface ServerIL

Parameters:

dc - Description of Parameter

clientTime - Description of Parameter

Throws:

javax.jms.JMSException

recover

public Xid[] recover(ConnectionToken dc,
                     int flags)
              throws Exception

Description copied from interface: Recoverable

Recover

Specified by:

recover in interface Recoverable

Parameters:

dc - the connnection token

flags - the recovery flags

Returns:

the xids

Throws:

Exception - for any error