HAILServerIL (JBoss Cluster API) - JBoss 4.0.1 sp1 cluster API Documentation 英文版文档

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.jboss.mq.il.ha
Class HAILServerIL

java.lang.Object
  org.jboss.mq.il.uil2.UILServerIL
      org.jboss.mq.il.ha.HAILServerIL

All Implemented Interfaces:: Cloneable, EventListener, org.jboss.mq.il.uil2.msgs.MsgTypes, javax.management.NotificationListener, Serializable, org.jboss.mq.il.ServerIL

public class HAILServerIL
extends org.jboss.mq.il.uil2.UILServerIL
implements Cloneable, org.jboss.mq.il.uil2.msgs.MsgTypes, Serializable, org.jboss.mq.il.ServerIL, javax.management.NotificationListener

The HAILServerIL is created on the server and copied to the client during connection factory lookups. It represents the transport interface to the JMS server.

Version:: $Revision: 1.3 $
Author:: Scott.Stark@jboss.org, ivelin@apache.org
See Also:: Serialized Form

Field Summary

static String HAIL_SHARED_STATE_SERVICE


Fields inherited from class org.jboss.mq.il.uil2.UILServerIL

socket, socketMgr

Fields inherited from interface org.jboss.mq.il.uil2.msgs.MsgTypes

m_acknowledge, m_addMessage, m_authenticate, m_browse, m_checkID, m_checkUser, m_close, m_connectionClosing, m_createQueue, m_createTopic, m_deleteTemporaryDestination, m_destroySubscription, m_getID, m_getTemporaryQueue, m_getTemporaryTopic, m_ping, m_pong, m_receive, m_receiveRequest, m_setEnabled, m_setSpyDistributedConnection, m_subscribe, m_transact, m_unsubscribe

Constructor Summary

HAILServerIL(String socketFactoryName, boolean enableTcpNoDelay, int bufferSize, int chunkSize)
          Constructor for the UILServerIL object

Method Summary

protected void addHAILNotificationListener()


protected void createConnection()
          Used to establish a new connection to the server.

protected InetAddress getServerAddress()


protected int getServerPort()


void handleNotification(javax.management.Notification notification, Object handback)
          Notification that the singleton HAIL server moved.

void ping(org.jboss.mq.ConnectionToken dc, long clientTime)
          Overrides the UIL ping to take into account occasional migration of the UIL server singleton

protected void removeHAILNotificationListener()


Methods inherited from class org.jboss.mq.il.uil2.UILServerIL

acknowledge, addMessage, authenticate, browse, checkConnection, checkID, checkUser, clone, cloneServerIL, connectionClosing, createQueue, createTopic, deleteTemporaryDestination, destroyConnection, destroySubscription, getID, getTemporaryQueue, getTemporaryTopic, receive, setConnectionToken, setEnabled, subscribe, transact, unsubscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jboss.mq.il.ServerIL

acknowledge, addMessage, authenticate, browse, checkID, checkUser, cloneServerIL, connectionClosing, createQueue, createTopic, deleteTemporaryDestination, destroySubscription, getID, getTemporaryQueue, getTemporaryTopic, receive, setConnectionToken, setEnabled, subscribe, transact, unsubscribe

Field Detail

HAIL_SHARED_STATE_SERVICE

public static final String HAIL_SHARED_STATE_SERVICE

See Also:: Constant Field Values

Constructor Detail

HAILServerIL

public HAILServerIL(String socketFactoryName,
                    boolean enableTcpNoDelay,
                    int bufferSize,
                    int chunkSize)
             throws Exception

Constructor for the UILServerIL object

Method Detail

createConnection

protected void createConnection()
                         throws Exception

Used to establish a new connection to the server. Almost identical to the UIL2 implementation, except for the fact that the server address and port are obtained from the HAILSharedState MBean instead of deployment-time properties.

Throws:: Exception - Description of Exception

getServerAddress

protected InetAddress getServerAddress()
                                throws javax.management.AttributeNotFoundException,
                                       javax.management.InstanceNotFoundException,
                                       javax.management.MBeanException,
                                       javax.management.ReflectionException

Throws:: javax.management.AttributeNotFoundException; javax.management.InstanceNotFoundException; javax.management.MBeanException; javax.management.ReflectionException

getServerPort

protected int getServerPort()
                     throws javax.management.AttributeNotFoundException,
                            javax.management.InstanceNotFoundException,
                            javax.management.MBeanException,
                            javax.management.ReflectionException

Throws:: javax.management.AttributeNotFoundException; javax.management.InstanceNotFoundException; javax.management.MBeanException; javax.management.ReflectionException

ping

public void ping(org.jboss.mq.ConnectionToken dc,
                 long clientTime)
          throws Exception

Overrides the UIL ping to take into account occasional migration of the UIL server singleton

Specified by:: ping in interface org.jboss.mq.il.ServerIL

Parameters:: dc - Description of Parameter; clientTime - Description of Parameter
Throws:: Exception - Description of Exception

addHAILNotificationListener

protected void addHAILNotificationListener()
                                    throws javax.management.InstanceNotFoundException

Throws:: javax.management.InstanceNotFoundException

removeHAILNotificationListener

protected void removeHAILNotificationListener()
                                       throws javax.management.InstanceNotFoundException,
                                              javax.management.ListenerNotFoundException

Throws:: javax.management.InstanceNotFoundException; javax.management.ListenerNotFoundException

handleNotification

public void handleNotification(javax.management.Notification notification,
                               Object handback)

Notification that the singleton HAIL server moved. Close connection and unsubscribe.

Specified by:: handleNotification in interface javax.management.NotificationListener