@Command(name="consumer",
description="It will send consume messages from an instance")
public class Consumer
extends DestAbstract
brokerURL, password, usercontext, verbose| Constructor and Description |
|---|
Consumer() |
| Modifier and Type | Method and Description |
|---|---|
Object |
execute(ActionContext context) |
createConnectionFactoryinput, inputPassword, isSilentInput, setSilentInputgetBrokerHome, getBrokerInstance, getBrokerURIInstance, isVerbose, setHomeValuespublic Object execute(ActionContext context) throws Exception
execute in interface Actionexecute in class InputAbstractExceptionCopyright © 2023 The Apache Software Foundation. All Rights Reserved.