public class SlackProducer extends DefaultProducer
log
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
Constructor and Description |
---|
SlackProducer(SlackEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
String |
asJson(SlackMessage message)
Returns a JSON string to be posted to the Slack API
|
void |
process(Exchange exchange)
Processes the message exchange
|
createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public SlackProducer(SlackEndpoint endpoint)
public void process(Exchange exchange) throws Exception
Processor
exchange
- the message exchangeException
- if an internal processing error has occurred.public String asJson(SlackMessage message)
Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.