org.jboss.mq.il.rmi
Class RMIServerIL

java.lang.Object
  java.rmi.server.RemoteObject
      java.rmi.server.RemoteServer
          java.rmi.server.UnicastRemoteObject
              org.jboss.mq.il.rmi.RMIServerIL

All Implemented Interfaces:

Serializable, Remote, RMIServerILRemote, ServerIL

public class RMIServerIL
extends UnicastRemoteObject
implements RMIServerILRemote

The JVM implementation of the ServerIL object

Version:

$Revision: 1.9.6.2 $

Author:

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

See Also:

Serialized Form

Field Summary

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

RMIServerIL(Invoker s)
Constructor for the RMIServerIL object

Method Summary

void	acknowledge(ConnectionToken dc, AcknowledgementRequest item) #Description of the Method
void	addMessage(ConnectionToken dc, SpyMessage val) Adds a feature to the Message attribute of the RMIServerIL object
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) #Description of the Method
String	checkUser(String userName, String password) #Description of the Method
ServerIL	cloneServerIL() No need to clone because there are no instance variables tha can get clobbered.
void	connectionClosing(ConnectionToken dc) #Description of the Method
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) #Description of the Method
String	getID() Gets the ID attribute of the RMIServerIL object
javax.jms.TemporaryQueue	getTemporaryQueue(ConnectionToken dc) Gets the TemporaryQueue attribute of the RMIServerIL object
javax.jms.TemporaryTopic	getTemporaryTopic(ConnectionToken dc) Gets the TemporaryTopic attribute of the RMIServerIL object
void	ping(ConnectionToken dc, long clientTime) #Description of the Method
SpyMessage	receive(ConnectionToken dc, int subscriberId, long wait) #Description of the Method
void	setConnectionToken(ConnectionToken newConnectionToken) Sets the ConnectionToken attribute of the RMIServerIL object
void	setEnabled(ConnectionToken dc, boolean enabled) Sets the Enabled attribute of the RMIServerIL object
void	subscribe(ConnectionToken dc, Subscription s) #Description of the Method
void	transact(ConnectionToken dc, TransactionRequest t) #Description of the Method
void	unsubscribe(ConnectionToken dc, int subscriptionId) #Description of the Method

Methods inherited from class java.rmi.server.UnicastRemoteObject

clone, exportObject, exportObject, exportObject, unexportObject

Methods inherited from class java.rmi.server.RemoteServer

getClientHost, getLog, setLog

Methods inherited from class java.rmi.server.RemoteObject

equals, getRef, hashCode, toString, toStub

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

RMIServerIL

public RMIServerIL(Invoker s)
            throws RemoteException

Constructor for the RMIServerIL object

Parameters:

s - Description of Parameter

Throws:

RemoteException - Description of Exception

Method Detail

setConnectionToken

public void setConnectionToken(ConnectionToken newConnectionToken)

Sets the ConnectionToken attribute of the RMIServerIL object

Specified by:

setConnectionToken in interface ServerIL

Parameters:

newConnectionToken - The new ConnectionToken value

setEnabled

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

Sets the Enabled attribute of the RMIServerIL 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

Gets the ID attribute of the RMIServerIL object

Specified by:

getID in interface ServerIL

Returns:

The ID value

Throws:

javax.jms.JMSException - Description of Exception

getTemporaryQueue

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

Gets the TemporaryQueue attribute of the RMIServerIL object

Specified by:

getTemporaryQueue in interface ServerIL

Parameters:

dc - Description of Parameter

Returns:

The TemporaryQueue value

Throws:

javax.jms.JMSException - Description of Exception

getTemporaryTopic

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

Gets the TemporaryTopic attribute of the RMIServerIL object

Specified by:

getTemporaryTopic in interface ServerIL

Parameters:

dc - Description of Parameter

Returns:

The TemporaryTopic value

Throws:

javax.jms.JMSException - Description of Exception

cloneServerIL

public ServerIL cloneServerIL()

No need to clone because there are no instance variables tha can get clobbered. All Multiple connections can share the same JVMServerIL object

Specified by:

cloneServerIL in interface ServerIL

Returns:

Description of the Returned Value

addMessage

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

Adds a feature to the Message attribute of the RMIServerIL object

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 - Description of Exception

createTopic

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

#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 - Description of Exception

createQueue

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

#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 - Description of Exception

deleteTemporaryDestination

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

#Description of the Method

Specified by:

deleteTemporaryDestination in interface ServerIL

Parameters:

dc - Description of Parameter

dest - Description of Parameter

Throws:

javax.jms.JMSException - Description of Exception

checkID

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

#Description of the Method

Specified by:

checkID in interface ServerIL

Parameters:

ID - Description of Parameter

Throws:

javax.jms.JMSException - Description of Exception

connectionClosing

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

#Description of the Method

Specified by:

connectionClosing in interface ServerIL

Parameters:

dc - Description of Parameter

Throws:

javax.jms.JMSException - Description of Exception

acknowledge

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

#Description of the Method

Specified by:

acknowledge in interface ServerIL

Parameters:

dc - Description of Parameter

item - Description of Parameter

Throws:

Exception - Description of Exception

RemoteException - Description of Exception

browse

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

#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 of the Method

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 of the Method

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 of the Method

Specified by:

destroySubscription in interface ServerIL

Parameters:

id - Description of Parameter

Throws:

Exception - Description of Exception

checkUser

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

#Description of the Method

Specified by:

checkUser in interface ServerIL

Parameters:

userName - Description of Parameter

password - Description of Parameter

Returns:

Description of the Returned Value

Throws:

javax.jms.JMSException - Description of Exception

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

#Description of the Method

Specified by:

subscribe in interface ServerIL

Parameters:

dc - Description of Parameter

s - Description of Parameter

Throws:

Exception - Description of Exception

transact

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

#Description of the Method

Specified by:

transact in interface ServerIL

Parameters:

dc - Description of Parameter

t - Description of Parameter

Throws:

javax.jms.JMSException - Description of Exception

ping

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

#Description of the Method

Specified by:

ping in interface ServerIL

Parameters:

dc - Description of Parameter

clientTime - Description of Parameter

Throws:

javax.jms.JMSException - Description of Exception