@UriEndpoint(firstVersion="2.23.0",
scheme="ipfs",
title="IPFS",
syntax="ipfs:host:port/cmd",
producerOnly=true,
label="file,ipfs")
public class IPFSEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_TIMEOUT |
Constructor and Description |
---|
IPFSEndpoint(String uri,
IPFSComponent component,
IPFSConfiguration config) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
IPFSComponent |
getComponent() |
io.nessus.ipfs.client.IPFSClient |
getIPFSClient() |
boolean |
isSingleton() |
void |
setClient(io.nessus.ipfs.client.IPFSClient client) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStop, equals, getCamelContext, 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 static final long DEFAULT_TIMEOUT
public IPFSEndpoint(String uri, IPFSComponent component, IPFSConfiguration config)
public io.nessus.ipfs.client.IPFSClient getIPFSClient()
public void setClient(io.nessus.ipfs.client.IPFSClient client)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
public IPFSComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
Apache Camel