org.apache.cayenne.event
Class JavaGroupsBridge

java.lang.Object
  extended by org.apache.cayenne.event.EventBridge
      extended by org.apache.cayenne.event.JavaGroupsBridge
All Implemented Interfaces:
EventListener

public class JavaGroupsBridge
extends EventBridge

Implementation of EventBridge that passes and receives events via JavaGroups communication software.

Since:
1.1

Field Summary
protected  PullPushAdapter adapter
           
protected  Channel channel
           
protected  String configURL
           
protected  String multicastAddress
           
protected  String multicastPort
           
protected  byte[] state
           
 
Fields inherited from class org.apache.cayenne.event.EventBridge
eventManager, externalEventSource, externalSubject, localSubjects, mode, RECEIVE_EXTERNAL, RECEIVE_LOCAL, RECEIVE_LOCAL_EXTERNAL
 
Constructor Summary
JavaGroupsBridge(Collection<EventSubject> localSubjects, String externalSubject)
           
JavaGroupsBridge(EventSubject localSubject, String externalSubject)
          Creates new instance of JavaGroupsBridge.
 
Method Summary
protected  String buildConfigString()
          Creates JavaGroups configuration String, using preconfigured multicast port and address.
protected  Serializable eventToMessageObject(CayenneEvent event)
          Converts CayenneEvent to a serializable object that will be sent via JMS.
 String getConfigURL()
           
 String getMulticastAddress()
           
 String getMulticastPort()
           
 byte[] getState()
           
protected  CayenneEvent messageObjectToEvent(Serializable object)
          Converts a Serializable instance to CayenneEvent.
 void receive(Message message)
          Implementation of org.javagroups.MessageListener - a callback method to process incoming messages.
protected  void sendExternalEvent(CayenneEvent localEvent)
          Sends a Cayenne event over the transport supported by this bridge.
 void setConfigURL(String configURL)
           
 void setMulticastAddress(String multicastAddress)
           
 void setMulticastPort(String multicastPort)
           
 void setState(byte[] state)
           
protected  void shutdownExternal()
          Shuts down the external interface of the EventBridge, cleaning up and releasing any resources used to communicate external events.
protected  void startupExternal()
          Starts an external interface of the EventBridge.
 
Methods inherited from class org.apache.cayenne.event.EventBridge
convertToExternalSubject, getEventManager, getExternalEventSource, getExternalSubject, getLocalSubjects, isRunning, onExternalEvent, receivesExternalEvents, receivesLocalEvents, shutdown, startup, startup, startup
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

state

protected byte[] state

channel

protected Channel channel

adapter

protected PullPushAdapter adapter

multicastAddress

protected String multicastAddress

multicastPort

protected String multicastPort

configURL

protected String configURL
Constructor Detail

JavaGroupsBridge

public JavaGroupsBridge(EventSubject localSubject,
                        String externalSubject)
Creates new instance of JavaGroupsBridge.


JavaGroupsBridge

public JavaGroupsBridge(Collection<EventSubject> localSubjects,
                        String externalSubject)
Since:
1.2
Method Detail

getConfigURL

public String getConfigURL()

setConfigURL

public void setConfigURL(String configURL)

getMulticastAddress

public String getMulticastAddress()

setMulticastAddress

public void setMulticastAddress(String multicastAddress)

getMulticastPort

public String getMulticastPort()

setMulticastPort

public void setMulticastPort(String multicastPort)

getState

public byte[] getState()

setState

public void setState(byte[] state)

receive

public void receive(Message message)
Implementation of org.javagroups.MessageListener - a callback method to process incoming messages.


startupExternal

protected void startupExternal()
                        throws Exception
Description copied from class: EventBridge
Starts an external interface of the EventBridge.

Specified by:
startupExternal in class EventBridge
Throws:
Exception

buildConfigString

protected String buildConfigString()
Creates JavaGroups configuration String, using preconfigured multicast port and address.


shutdownExternal

protected void shutdownExternal()
                         throws Exception
Description copied from class: EventBridge
Shuts down the external interface of the EventBridge, cleaning up and releasing any resources used to communicate external events.

Specified by:
shutdownExternal in class EventBridge
Throws:
Exception

sendExternalEvent

protected void sendExternalEvent(CayenneEvent localEvent)
                          throws Exception
Description copied from class: EventBridge
Sends a Cayenne event over the transport supported by this bridge.

Specified by:
sendExternalEvent in class EventBridge
Throws:
Exception

eventToMessageObject

protected Serializable eventToMessageObject(CayenneEvent event)
                                     throws Exception
Converts CayenneEvent to a serializable object that will be sent via JMS. Default implementation simply returns the event, but subclasses can customize this behavior.

Throws:
Exception

messageObjectToEvent

protected CayenneEvent messageObjectToEvent(Serializable object)
                                     throws Exception
Converts a Serializable instance to CayenneEvent. Returns null if the object is not supported. Default implementation simply tries to cast the object to CayenneEvent, but subclasses can customize this behavior.

Throws:
Exception


Copyright © 2001-2011 Apache Cayenne. All Rights Reserved.