org.distributeme.support.eventservice

Class DiMeRemoteEventChannelSupplierProxy

java.lang.Object

org.distributeme.support.eventservice.DiMeRemoteEventChannelSupplierProxy

All Implemented Interfaces:

net.anotheria.anoprise.eventservice.EventChannel, net.anotheria.anoprise.eventservice.EventChannelProxy, net.anotheria.anoprise.eventservice.EventChannelSupplierProxy, net.anotheria.anoprise.eventservice.RemoteEventChannelSupplierProxy

public class DiMeRemoteEventChannelSupplierProxy
extends Object
implements net.anotheria.anoprise.eventservice.RemoteEventChannelSupplierProxy

Method Summary

Methods

Modifier and Type	Method and Description
void	addConsumer(net.anotheria.anoprise.eventservice.EventServiceConsumer consumer)
void	addConsumerProxy(net.anotheria.anoprise.eventservice.EventChannelConsumerProxy proxy)
void	deliverEvent(byte[] eventData)
String	getName()
boolean	isLocal()
void	push(net.anotheria.anoprise.eventservice.Event e)
void	removeConsumer(net.anotheria.anoprise.eventservice.EventServiceConsumer consumer)
void	removeConsumerProxy(net.anotheria.anoprise.eventservice.EventChannelConsumerProxy proxy)

Methods inherited from class java.lang.Object

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

Method Detail

deliverEvent

public void deliverEvent(byte[] eventData)

Specified by:

deliverEvent in interface net.anotheria.anoprise.eventservice.RemoteEventChannelSupplierProxy

addConsumer

public void addConsumer(net.anotheria.anoprise.eventservice.EventServiceConsumer consumer)

Specified by:

addConsumer in interface net.anotheria.anoprise.eventservice.EventChannel

getName

public String getName()

Specified by:

getName in interface net.anotheria.anoprise.eventservice.EventChannel

push

public void push(net.anotheria.anoprise.eventservice.Event e)

Specified by:

push in interface net.anotheria.anoprise.eventservice.EventChannel

removeConsumer

public void removeConsumer(net.anotheria.anoprise.eventservice.EventServiceConsumer consumer)

Specified by:

removeConsumer in interface net.anotheria.anoprise.eventservice.EventChannel

addConsumerProxy

public void addConsumerProxy(net.anotheria.anoprise.eventservice.EventChannelConsumerProxy proxy)

Specified by:

addConsumerProxy in interface net.anotheria.anoprise.eventservice.EventChannelSupplierProxy

removeConsumerProxy

public void removeConsumerProxy(net.anotheria.anoprise.eventservice.EventChannelConsumerProxy proxy)

Specified by:

removeConsumerProxy in interface net.anotheria.anoprise.eventservice.EventChannelSupplierProxy

isLocal

public boolean isLocal()

Specified by:

isLocal in interface net.anotheria.anoprise.eventservice.EventChannelProxy