public class PortFactory<X extends Port<X>> extends Object implements ConfiguredObjectTypeFactory<X>
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_AMQP_BINDING |
static boolean |
DEFAULT_AMQP_NEED_CLIENT_AUTH |
static int |
DEFAULT_AMQP_RECEIVE_BUFFER_SIZE |
static int |
DEFAULT_AMQP_SEND_BUFFER_SIZE |
static boolean |
DEFAULT_AMQP_TCP_NO_DELAY |
static boolean |
DEFAULT_AMQP_WANT_CLIENT_AUTH |
static Transport |
DEFAULT_TRANSPORT |
Constructor and Description |
---|
PortFactory() |
Modifier and Type | Method and Description |
---|---|
X |
create(ConfiguredObjectFactory factory,
Map<String,Object> attributes,
ConfiguredObject<?>... parents) |
com.google.common.util.concurrent.ListenableFuture<X> |
createAsync(ConfiguredObjectFactory factory,
Map<String,Object> attributes,
ConfiguredObject<?>... parents) |
Class<? super Port> |
getCategoryClass() |
ConfiguredObjectTypeFactory<X> |
getPortFactory(ConfiguredObjectFactory factory,
Map<String,Object> attributes,
Broker<?> broker) |
String |
getType() |
UnresolvedConfiguredObject<X> |
recover(ConfiguredObjectFactory factory,
ConfiguredObjectRecord record,
ConfiguredObject<?>... parents) |
public static final int DEFAULT_AMQP_SEND_BUFFER_SIZE
public static final int DEFAULT_AMQP_RECEIVE_BUFFER_SIZE
public static final boolean DEFAULT_AMQP_NEED_CLIENT_AUTH
public static final boolean DEFAULT_AMQP_WANT_CLIENT_AUTH
public static final boolean DEFAULT_AMQP_TCP_NO_DELAY
public static final String DEFAULT_AMQP_BINDING
public static final Transport DEFAULT_TRANSPORT
public Class<? super Port> getCategoryClass()
getCategoryClass
in interface ConfiguredObjectTypeFactory<X extends Port<X>>
public X create(ConfiguredObjectFactory factory, Map<String,Object> attributes, ConfiguredObject<?>... parents)
create
in interface ConfiguredObjectTypeFactory<X extends Port<X>>
public com.google.common.util.concurrent.ListenableFuture<X> createAsync(ConfiguredObjectFactory factory, Map<String,Object> attributes, ConfiguredObject<?>... parents)
createAsync
in interface ConfiguredObjectTypeFactory<X extends Port<X>>
public UnresolvedConfiguredObject<X> recover(ConfiguredObjectFactory factory, ConfiguredObjectRecord record, ConfiguredObject<?>... parents)
recover
in interface ConfiguredObjectTypeFactory<X extends Port<X>>
public ConfiguredObjectTypeFactory<X> getPortFactory(ConfiguredObjectFactory factory, Map<String,Object> attributes, Broker<?> broker)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.