public class Consumer extends DestAbstract
DEFAULT_MESSAGE_SERIALIZER
brokerURL, password, user
context, verbose
Constructor and Description |
---|
Consumer() |
Modifier and Type | Method and Description |
---|---|
Object |
execute(ActionContext context) |
getAddressFromFQQN, getFQQNFromDestination, getMessageSerializer, getQueueAttribute, getQueueFromFQQN, getQueueIdFromName, isFQQN, lookupDestination
createConnectionFactory, createCoreConnectionFactory, getClientID, getPassword, getProtocol, getUser, setClientID, setPassword, setProtocol, setUser
enableInput, input, input, inputBoolean, inputPassword, isSilentInput, setSilentInput
checkOptions, getBrokerEtc, getBrokerHome, getBrokerInstance, getBrokerURIInstance, isVerbose, setHomeValues
public Object execute(ActionContext context) throws Exception
execute
in interface Action
execute
in class InputAbstract
Exception
Copyright © 2020 JBoss by Red Hat. All rights reserved.