public class FabricMQGateway extends AbstractComponent
Constructor and Description |
---|
FabricMQGateway() |
Modifier and Type | Method and Description |
---|---|
protected TcpGateway |
addGateway(java.util.List<TcpGateway> gateways,
org.vertx.java.core.Vertx vertx,
ServiceMap serviceMap,
java.lang.String protocolName,
boolean enabled,
int listenPort,
LoadBalancer pathLoadBalancer,
LoadBalancer<ServiceDetails> serviceLoadBalancer) |
protected GatewayServiceTreeCache |
createListener() |
int |
getAmqpPort() |
org.apache.curator.framework.CuratorFramework |
getCurator() |
FabricService |
getFabricService() |
java.lang.String |
getHost() |
int |
getMqttPort() |
int |
getOpenWirePort() |
int |
getStompPort() |
VertxService |
getVertxService() |
int |
getWebsocketPort() |
java.lang.String |
getZooKeeperPath() |
boolean |
isAmqpEnabled() |
boolean |
isMqttEnabled() |
boolean |
isOpenWireEnabled() |
boolean |
isStompEnabled() |
boolean |
isWebsocketEnabled() |
void |
setAmqpEnabled(boolean amqpEnabled) |
void |
setAmqpPort(int amqpPort) |
void |
setCurator(org.apache.curator.framework.CuratorFramework curator) |
void |
setFabricService(FabricService fabricService) |
void |
setHost(java.lang.String host) |
void |
setMqttEnabled(boolean mqttEnabled) |
void |
setMqttPort(int mqttPort) |
void |
setOpenWireEnabled(boolean openWireEnabled) |
void |
setOpenWirePort(int openWirePort) |
void |
setStompEnabled(boolean stompEnabled) |
void |
setStompPort(int stompPort) |
void |
setVertxService(VertxService vertxService) |
void |
setWebsocketEnabled(boolean websocketEnabled) |
void |
setWebsocketPort(int websocketPort) |
void |
setZooKeeperPath(java.lang.String zooKeeperPath) |
void |
unsetCurator(org.apache.curator.framework.CuratorFramework curator) |
void |
unsetFabricService(FabricService fabricService) |
void |
unsetVertxService(VertxService vertxService) |
activateComponent, assertValid, deactivateComponent, isValid
protected GatewayServiceTreeCache createListener()
protected TcpGateway addGateway(java.util.List<TcpGateway> gateways, org.vertx.java.core.Vertx vertx, ServiceMap serviceMap, java.lang.String protocolName, boolean enabled, int listenPort, LoadBalancer pathLoadBalancer, LoadBalancer<ServiceDetails> serviceLoadBalancer)
public VertxService getVertxService()
public void setVertxService(VertxService vertxService)
public void unsetVertxService(VertxService vertxService)
public org.apache.curator.framework.CuratorFramework getCurator()
public void setCurator(org.apache.curator.framework.CuratorFramework curator)
public void unsetCurator(org.apache.curator.framework.CuratorFramework curator)
public FabricService getFabricService()
public void setFabricService(FabricService fabricService)
public void unsetFabricService(FabricService fabricService)
public java.lang.String getZooKeeperPath()
public void setZooKeeperPath(java.lang.String zooKeeperPath)
public java.lang.String getHost()
public void setHost(java.lang.String host)
public boolean isOpenWireEnabled()
public void setOpenWireEnabled(boolean openWireEnabled)
public int getOpenWirePort()
public void setOpenWirePort(int openWirePort)
public boolean isStompEnabled()
public void setStompEnabled(boolean stompEnabled)
public int getStompPort()
public void setStompPort(int stompPort)
public boolean isAmqpEnabled()
public void setAmqpEnabled(boolean amqpEnabled)
public int getAmqpPort()
public void setAmqpPort(int amqpPort)
public boolean isMqttEnabled()
public void setMqttEnabled(boolean mqttEnabled)
public int getMqttPort()
public void setMqttPort(int mqttPort)
public boolean isWebsocketEnabled()
public void setWebsocketEnabled(boolean websocketEnabled)
public int getWebsocketPort()
public void setWebsocketPort(int websocketPort)
Copyright © 2014 Red Hat. All Rights Reserved.