Package org.powertac.common.interfaces
Interface BrokerProxy
-
- All Known Implementing Classes:
BrokerProxyService
public interface BrokerProxy
BrokerProxy is responsible for handling in- and outgoing communication with brokers- Author:
- David Dauer
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
broadcastDeferredMessages()
Sends deferred messagesvoid
broadcastMessage(Object messageObject)
Send a message to all brokersvoid
broadcastMessages(List<?> messageObjects)
Sends a list of messages to all brokersvoid
registerBrokerMessageListener(Object listener, Class<?> msgType)
Sets up a dispatch listener for market messagesvoid
routeMessage(Object message)
Routes a message to server components.void
sendMessage(Broker broker, Object messageObject)
Send a message to a specific brokervoid
sendMessages(Broker broker, List<?> messageObjects)
Sends a list of messages to a specific brokervoid
setDeferredBroadcast(boolean b)
Holds up message transmission when true
-
-
-
Method Detail
-
sendMessage
void sendMessage(Broker broker, Object messageObject)
Send a message to a specific broker
-
sendMessages
void sendMessages(Broker broker, List<?> messageObjects)
Sends a list of messages to a specific broker
-
broadcastMessage
void broadcastMessage(Object messageObject)
Send a message to all brokers
-
broadcastMessages
void broadcastMessages(List<?> messageObjects)
Sends a list of messages to all brokers
-
routeMessage
void routeMessage(Object message)
Routes a message to server components. Used to route both incoming messages and messages generated by internal "broker-like" entities, such as gencos and the default broker. Messages from non-enabled brokers will be silently dropped into the bit-bucket.
-
registerBrokerMessageListener
void registerBrokerMessageListener(Object listener, Class<?> msgType)
Sets up a dispatch listener for market messages
-
setDeferredBroadcast
void setDeferredBroadcast(boolean b)
Holds up message transmission when true
-
broadcastDeferredMessages
void broadcastDeferredMessages()
Sends deferred messages
-
-