ch.algotrader.event.dispatch

Interface EventDispatcher

All Known Implementing Classes:

DistributedEventDispatcher, LocalEventDispatcher

public interface EventDispatcher

Platform wide communication interface capable of submitting events to multiple Engines and EventListeners both, inside and outside of the current JRE.

Method Summary

Modifier and Type	Method and Description
void	broadcast(java.lang.Object event, java.util.Set<EventRecipient> recipients) Broadcasts a generic event to recipients.
void	broadcastInSameThread(java.lang.Object event, java.util.Set<EventRecipient> recipients) Guarantees broadcasting to listeners at the caller's thread
boolean	isMarketDataSubscribed(long securityId, java.lang.String strategyName) Tests if there is a market data registration for the given strategy and security.
boolean	isMarketDataSubscribedByAnyStrategy(long securityId)
void	resendPastEvent(java.lang.String strategyName, java.lang.Object event) Re-sends past event related to the given strategy to internal recipients such as UI primarily to restore strategy state upon startup.
void	sendEvent(java.lang.String strategyName, java.lang.Object event) Sends event related to the given strategy to local or remote recipients.
void	sendMarketDataEvent(MarketDataEventVO marketDataEvent) Sends market data event all subscribed strategies running either locally or remotely.
void	shutdown()
void	subscribeMarketData(java.lang.String strategyName, long securityId) Registers market data subscription for the given strategy and security
void	unsubscribeMarketData(java.lang.String strategyName, long securityId) Un-registers market data subscription for the given strategy and security

Method Detail

sendEvent

void sendEvent(java.lang.String strategyName,
               java.lang.Object event)

Sends event related to the given strategy to local or remote recipients.

resendPastEvent

void resendPastEvent(java.lang.String strategyName,
                     java.lang.Object event)

Re-sends past event related to the given strategy to internal recipients such as UI primarily to restore strategy state upon startup.

isMarketDataSubscribed

boolean isMarketDataSubscribed(long securityId,
                               java.lang.String strategyName)

Tests if there is a market data registration for the given strategy and security.

subscribeMarketData

void subscribeMarketData(java.lang.String strategyName,
                         long securityId)

Registers market data subscription for the given strategy and security

unsubscribeMarketData

void unsubscribeMarketData(java.lang.String strategyName,
                           long securityId)

Un-registers market data subscription for the given strategy and security

isMarketDataSubscribedByAnyStrategy

boolean isMarketDataSubscribedByAnyStrategy(long securityId)

sendMarketDataEvent

void sendMarketDataEvent(MarketDataEventVO marketDataEvent)

Sends market data event all subscribed strategies running either locally or remotely.

broadcast

void broadcast(java.lang.Object event,
               java.util.Set<EventRecipient> recipients)

Broadcasts a generic event to recipients.

broadcastInSameThread

void broadcastInSameThread(java.lang.Object event,
                           java.util.Set<EventRecipient> recipients)

Guarantees broadcasting to listeners at the caller's thread

shutdown

void shutdown()