public class BrokerClientImpl extends Object implements Broker, MessageListener
Constructor and Description |
---|
BrokerClientImpl(ModuleContext module) |
Modifier and Type | Method and Description |
---|---|
void |
dispose()
Release the resources
|
String |
getBrokerName() |
void |
handleSendError(ChannelMessage message,
CommunicationConnectorException e)
Callback for error handling
|
boolean |
init() |
void |
messageReceived(ChannelMessage message)
Callback for the reception of messages
|
void |
setStop(boolean stop) |
void |
startBrokerClient() |
BrokerMessage |
unmarshall(String message)
From String to Broker Message
|
public BrokerClientImpl(ModuleContext module)
public void startBrokerClient()
public void setStop(boolean stop)
public void handleSendError(ChannelMessage message, CommunicationConnectorException e)
MessageListener
handleSendError
in interface MessageListener
public void messageReceived(ChannelMessage message)
MessageListener
messageReceived
in interface MessageListener
public String getBrokerName()
getBrokerName
in interface Broker
public void dispose()
Broker
public BrokerMessage unmarshall(String message)
Broker
unmarshall
in interface Broker
Copyright © 2018 universAAL Consortium. All rights reserved.