public class SessionConfig extends Object
Constructor and Description |
---|
SessionConfig() |
SessionConfig(String sessionName,
int acknowledgeMode,
ConsumerConfig... consumers) |
SessionConfig(String sessionName,
int acknowledgeMode,
List<ConsumerConfig> consumers,
List<ProducerConfig> producers) |
SessionConfig(String sessionName,
int acknowledgeMode,
ProducerConfig... producers) |
Modifier and Type | Method and Description |
---|---|
List<Command> |
createCommands(String connectionName) |
int |
getAcknowledgeMode() |
List<ConsumerConfig> |
getConsumers() |
List<ProducerConfig> |
getProducers() |
String |
getSessionName() |
int |
getTotalNumberOfParticipants() |
public SessionConfig()
public SessionConfig(String sessionName, int acknowledgeMode, ProducerConfig... producers)
public SessionConfig(String sessionName, int acknowledgeMode, ConsumerConfig... consumers)
public SessionConfig(String sessionName, int acknowledgeMode, List<ConsumerConfig> consumers, List<ProducerConfig> producers)
public int getAcknowledgeMode()
public String getSessionName()
public List<ProducerConfig> getProducers()
public List<ConsumerConfig> getConsumers()
public int getTotalNumberOfParticipants()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.