@UriEndpoint(firstVersion="2.22.0", scheme="web3j", title="Web3j Ethereum Blockchain", syntax="web3j:nodeAddress", consumerClass=Web3jConsumer.class, label="bitcoin,blockchain") public class Web3jEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
Web3jEndpoint(String uri,
String remaining,
Web3jComponent component,
Web3jConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
static org.web3j.protocol.core.methods.request.EthFilter |
buildEthFilter(org.web3j.protocol.core.DefaultBlockParameter fromBlock,
org.web3j.protocol.core.DefaultBlockParameter toBlock,
List<String> addresses,
List<String> topics) |
static org.web3j.protocol.core.methods.request.ShhFilter |
buildShhFilter(String data,
List<String> topics) |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
String |
getNodeAddress() |
org.web3j.protocol.Web3j |
getWeb3j() |
boolean |
isSingleton() |
void |
setNodeAddress(String nodeAddress)
Sets the node address used to communicate
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, 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 Web3jEndpoint(String uri, String remaining, Web3jComponent component, Web3jConfiguration configuration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public org.web3j.protocol.Web3j getWeb3j()
public boolean isSingleton()
public String getNodeAddress()
public void setNodeAddress(String nodeAddress)
public static org.web3j.protocol.core.methods.request.EthFilter buildEthFilter(org.web3j.protocol.core.DefaultBlockParameter fromBlock, org.web3j.protocol.core.DefaultBlockParameter toBlock, List<String> addresses, List<String> topics)
Apache Camel