Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.gbean
Class ActiveMQConnectorGBean  view ActiveMQConnectorGBean download ActiveMQConnectorGBean.java

java.lang.Object
  extended byorg.activemq.gbean.ActiveMQConnectorGBean
All Implemented Interfaces:
ActiveMQConnector, org.apache.geronimo.gbean.GBeanLifecycle

public class ActiveMQConnectorGBean
extends java.lang.Object
implements org.apache.geronimo.gbean.GBeanLifecycle, ActiveMQConnector

Default implementation of the ActiveMQ connector

Version:
$Revision: 1.1.1.1 $

Field Summary
private  org.activemq.broker.BrokerConnector brokerConnector
           
private  ActiveMQContainer container
           
static org.apache.geronimo.gbean.GBeanInfo GBEAN_INFO
           
private  java.lang.String host
           
private  org.apache.commons.logging.Log log
           
private  java.lang.String path
           
private  int port
           
private  java.lang.String protocol
           
private  java.lang.String query
           
private  java.lang.String urlAsStarted
           
private  org.activemq.io.WireFormat wireFormat
           
 
Fields inherited from interface org.activemq.gbean.ActiveMQConnector
CONNECTOR_J2EE_TYPE
 
Constructor Summary
ActiveMQConnectorGBean(ActiveMQContainer container, java.lang.String protocol, java.lang.String host, int port)
           
 
Method Summary
protected  org.activemq.broker.BrokerConnector createBrokerConnector(java.lang.String url)
           
 void doFail()
          Fails the GBean.
 void doStart()
          Starts the GBean.
 void doStop()
          Stops the target.
static org.apache.geronimo.gbean.GBeanInfo getGBeanInfo()
           
 java.lang.String getHost()
           
 java.net.InetSocketAddress getListenAddress()
           
 java.lang.String getPath()
           
 int getPort()
           
 java.lang.String getProtocol()
           
 java.lang.String getQuery()
           
 java.lang.String getUrl()
           
 org.activemq.io.WireFormat getWireFormat()
           
 void setHost(java.lang.String host)
           
 void setPath(java.lang.String path)
           
 void setPort(int port)
           
 void setProtocol(java.lang.String protocol)
           
 void setQuery(java.lang.String query)
           
 void setWireFormat(org.activemq.io.WireFormat wireFormat)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

private org.apache.commons.logging.Log log

brokerConnector

private org.activemq.broker.BrokerConnector brokerConnector

container

private ActiveMQContainer container

wireFormat

private org.activemq.io.WireFormat wireFormat

protocol

private java.lang.String protocol

host

private java.lang.String host

port

private int port

path

private java.lang.String path

query

private java.lang.String query

urlAsStarted

private java.lang.String urlAsStarted

GBEAN_INFO

public static final org.apache.geronimo.gbean.GBeanInfo GBEAN_INFO
Constructor Detail

ActiveMQConnectorGBean

public ActiveMQConnectorGBean(ActiveMQContainer container,
                              java.lang.String protocol,
                              java.lang.String host,
                              int port)
Method Detail

getProtocol

public java.lang.String getProtocol()

setProtocol

public void setProtocol(java.lang.String protocol)

getHost

public java.lang.String getHost()

setHost

public void setHost(java.lang.String host)

getPort

public int getPort()

setPort

public void setPort(int port)

getPath

public java.lang.String getPath()
Specified by:
getPath in interface ActiveMQConnector

setPath

public void setPath(java.lang.String path)
Specified by:
setPath in interface ActiveMQConnector

getQuery

public java.lang.String getQuery()
Specified by:
getQuery in interface ActiveMQConnector

setQuery

public void setQuery(java.lang.String query)
Specified by:
setQuery in interface ActiveMQConnector

getUrl

public java.lang.String getUrl()

getWireFormat

public org.activemq.io.WireFormat getWireFormat()

setWireFormat

public void setWireFormat(org.activemq.io.WireFormat wireFormat)

getListenAddress

public java.net.InetSocketAddress getListenAddress()

doStart

public void doStart()
             throws java.lang.Exception
Description copied from interface: org.apache.geronimo.gbean.GBeanLifecycle
Starts the GBean. This informs the GBean that it is about to transition to the running state.

Specified by:
doStart in interface org.apache.geronimo.gbean.GBeanLifecycle

doStop

public void doStop()
            throws java.lang.Exception
Description copied from interface: org.apache.geronimo.gbean.GBeanLifecycle
Stops the target. This informs the GBean that it is about to transition to the stopped state.

Specified by:
doStop in interface org.apache.geronimo.gbean.GBeanLifecycle

doFail

public void doFail()
Description copied from interface: org.apache.geronimo.gbean.GBeanLifecycle
Fails the GBean. This informs the GBean that it is about to transition to the failed state.

Specified by:
doFail in interface org.apache.geronimo.gbean.GBeanLifecycle

createBrokerConnector

protected org.activemq.broker.BrokerConnector createBrokerConnector(java.lang.String url)
                                                             throws java.lang.Exception

getGBeanInfo

public static org.apache.geronimo.gbean.GBeanInfo getGBeanInfo()