@UriEndpoint(firstVersion="2.19.0", scheme="milo-client", syntax="milo-client:endpointUri", title="OPC UA Client", consumerClass=MiloClientConsumer.class, label="iot") public class MiloClientEndpoint extends org.apache.camel.impl.DefaultEndpoint implements MiloClientItemConfiguration
Constructor and Description |
---|
MiloClientEndpoint(String uri,
MiloClientComponent component,
MiloClientConnection connection,
String endpointUri) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
MiloClientConnection |
getConnection() |
String |
getNode() |
Double |
getSamplingInterval() |
boolean |
isDefaultAwaitWrites() |
boolean |
isSingleton() |
NamespaceId |
makeNamespaceId() |
PartialNodeId |
makePartialNodeId() |
void |
setDefaultAwaitWrites(boolean defaultAwaitWrites) |
void |
setNode(String node) |
void |
setSamplingInterval(Double samplingInterval) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public MiloClientEndpoint(String uri, MiloClientComponent component, MiloClientConnection connection, String endpointUri)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public MiloClientConnection getConnection()
public PartialNodeId makePartialNodeId()
makePartialNodeId
in interface MiloClientItemConfiguration
public NamespaceId makeNamespaceId()
makeNamespaceId
in interface MiloClientItemConfiguration
public void setNode(String node)
public String getNode()
public Double getSamplingInterval()
getSamplingInterval
in interface MiloClientItemConfiguration
public void setSamplingInterval(Double samplingInterval)
public boolean isDefaultAwaitWrites()
public void setDefaultAwaitWrites(boolean defaultAwaitWrites)
Apache Camel