org.mortbay.jetty.asyncblazeds
Class AsyncAMFEndpoint

java.lang.Object
  extended by flex.management.ManageableComponent
      extended by flex.messaging.endpoints.AbstractEndpoint
          extended by flex.messaging.endpoints.BaseHTTPEndpoint
              extended by org.mortbay.jetty.asyncblazeds.BaseAsyncHTTPEndpoint
                  extended by org.mortbay.jetty.asyncblazeds.AsyncAMFEndpoint
All Implemented Interfaces:
flex.management.Manageable, flex.messaging.client.PollWaitListener, flex.messaging.config.ConfigurationConstants, flex.messaging.endpoints.Endpoint, flex.messaging.endpoints.Endpoint2, flex.messaging.FlexComponent, flex.messaging.FlexConfigurable

public class AsyncAMFEndpoint
extends BaseAsyncHTTPEndpoint


Field Summary
static java.lang.String LOG_CATEGORY
          The log category for this endpoint.
 
Fields inherited from class org.mortbay.jetty.asyncblazeds.BaseAsyncHTTPEndpoint
clientWaitInterval, lock, maxWaitingPollRequests, piggybackingEnabled, pollingEnabled, pollingIntervalMillis, waitingPollRequestsCount, waitInterval
 
Fields inherited from class flex.messaging.endpoints.BaseHTTPEndpoint
addNoCacheHeaders, controller, filterChain, HTTP_PROTOCOL_SCHEME, HTTPS_PROTOCOL_SCHEME, invalidateSessionOnDisconnect, loginAfterDisconnect, redirectURL
 
Fields inherited from class flex.messaging.endpoints.AbstractEndpoint
clientContextParsed, clientLoadBalancingUrls, clientType, connectTimeoutSeconds, deserializerClass, flexClientOutboundQueueProcessClass, flexClientOutboundQueueProcessor, flexClientOutboundQueueProcessorConfig, HEADER_NAME_CACHE_CONTROL, HEADER_NAME_EXPIRES, HEADER_NAME_PRAGMA, log, messagingVersion, parsedClientUrl, parsedForContext, parsedUrl, port, recordMessageSizes, recordMessageTimes, remote, requestTimeoutSeconds, serializationContext, serializerClass, server, serverOnly, typeMarshaller, url
 
Fields inherited from class flex.management.ManageableComponent
control, id, managed, NULL_COMPONENT_PROPERTY, parent, PROPERTY_CHANGE_AFTER_STARTUP, started, valid
 
Fields inherited from interface flex.messaging.config.ConfigurationConstants
ADAPTER_ATTR, ADAPTER_DEFINITION_CHILDREN, ADAPTER_DEFINITION_ELEMENT, ADAPTER_DEFINITION_REQ_CHILDREN, ADAPTER_ELEMENT, ADAPTERS_CHILDREN, ADAPTERS_ELEMENT, ADAPTIVE_FREQUENCY, ASYNC_MESSAGE_FILTERS_ELEMENT, ASYNC_MESSAGE_FILTERS_ELEMENT_CHILDREN, AUTH_METHOD_ELEMENT, CHANNEL_DEFINITION_CHILDREN, CHANNEL_DEFINITION_ELEMENT, CHANNEL_DEFINITION_REQ_CHILDREN, CHANNEL_DEFINITION_SERVER_REQ_CHILDREN, CHANNEL_ELEMENT, CHANNELS_ATTR, CHANNELS_CHILDREN, CHANNELS_ELEMENT, CLASS_AND_SERVER_ONLY_ERROR, CLASS_ATTR, CLASS_NOT_SPECIFIED, CLASS_OR_SERVER_ONLY_ERROR, CLIENT_LOAD_BALANCING_ELEMENT, CLUSTER_DEFINITION_CHILDREN, CLUSTER_DEFINITION_ELEMENT, CLUSTER_PROPERTIES_ATTR, CLUSTERING_CHILDREN, CLUSTERS_ELEMENT, CONNECT_TIMEOUT_SECONDS_ELEMENT, CONTEXT_PATH_ALT_TOKEN, CONTEXT_PATH_TOKEN, DEFAULT_ATTR, DEFAULT_CHANNELS_CHILDREN, DEFAULT_CHANNELS_ELEMENT, DEFAULT_LOCALE_ELEMENT, DEFAULT_SECURITY_CONSTRAINT_ELEMENT, DEST_NEEDS_ADAPTER, DEST_NEEDS_CHANNEL, DESTINATION_ADAPTER_CHILDREN, DESTINATION_ATTR, DESTINATION_CHANNEL_REQ_CHILDREN, DESTINATION_CHANNELS_CHILDREN, DESTINATION_CHILDREN, DESTINATION_ELEMENT, DESTINATION_INCLUDE_CHILDREN, DESTINATION_INCLUDE_ELEMENT, DESTINATION_REQ_CHILDREN, DESTINATIONS_CHILDREN, DESTINATIONS_ELEMENT, DUPLICATE_CHANNEL_ERROR, DUPLICATE_COMPONENT_ID, DUPLICATE_DEFAULT_ADAPTER, DUPLICATE_DEST_ID, DUPLICATE_DESTINATION_ERROR, DUPLICATE_SERVICE_ERROR, EMBEDDED_SECURITY_CHILDREN, EMPTY_STRING, ENABLE_SMALL_MESSAGES_ELEMENT, ENABLED_ELEMENT, ENDPOINT_CHILDREN, ENDPOINT_ELEMENT, ENFORCE_ENDOINT_VALIDATION, ERR_MSG_CLIENT_LOAD_BALANCING_URL_WITH_TOKEN, ERR_MSG_EMPTY_CLIENT_LOAD_BALANCING_ELEMENT, ERR_MSG_EMTPY_CLIENT_LOAD_BALACNING_URL, FACTORIES_CHILDREN, FACTORIES_ELEMENT, FACTORY_ELEMENT, FACTORY_REQ_CHILDREN, FALSE_STRING, FILTER_CHILDREN, FILTER_ELEMENT, FILTER_REQ_CHILDREN, FILTERS_CHILDREN, FILTERS_ELEMENT, FLEX_CLIENT_CHILDREN, FLEX_CLIENT_ELEMENT, FLEX_CLIENT_HEARTBEAT_INTERVAL_MILLIS, FLEX_CLIENT_OUTBOUND_QUEUE_PROCESSOR_ELEMENT, FLEX_CLIENT_OUTBOUND_QUEUE_PROCESSOR_REQ_CHILDREN, FLEX_CLIENT_RELIABLE_RECONNECT_DURATION_MILLIS, FLEX_CLIENT_TIMEOUT_MINUTES_ELEMENT, ID_ATTR, INVALID_DEFAULT_CHANNEL, INVALID_DESTINATION_INCLUDE_ROOT, INVALID_ENDPOINT_PORT, INVALID_FLEX_CLIENT_HEARTBEAT_INTERVAL_MILLIS, INVALID_FLEX_CLIENT_RELIABLE_RECONNECT_DURATION_MILLIS, INVALID_FLEX_CLIENT_TIMEOUT, INVALID_ID, INVALID_ID_IN_SERVICE, INVALID_REF_IN_DEST, INVALID_SECURITY_CONSTRAINT_REF, INVALID_SERVICE_INCLUDE_ROOT, INVALID_SERVICES_ROOT, INVALID_VALUE_FOR_PROPERTY_OF_COMPONENT_WITH_ID, IP_ADDRESS_PATTERN, IRREPLACABLE_TOKEN, LEVEL_ATTR, LIST_DELIMITERS, LOCALE_CHILDREN, LOCALE_ELEMENT, LOGGING_CHILDREN, LOGGING_ELEMENT, LOGIN_AFTER_DISCONNECT_ELEMENT, LOGIN_COMMAND_CHILDREN, LOGIN_COMMAND_ELEMENT, LOGIN_COMMAND_REQ_CHILDREN, MANAGEABLE_ELEMENT, MESSAGE_TYPES_ATTR, METADATA_ELEMENT, MISSING_ATTRIBUTE, MISSING_ELEMENT, NULL_COMPONENT, NULL_COMPONENT_ID, PARSER_INIT_ERROR, PARSER_INTERNAL_ERROR, PATTERN_ELEMENT, PER_CLIENT_AUTH, PIGGYBACKING_ENABLED_ELEMENT, POLLING_ENABLED_ELEMENT, POLLING_INTERVAL_MILLIS_ELEMENT, POLLING_INTERVAL_SECONDS_ELEMENT, PROPERTIES_ELEMENT, RECORD_MESSAGE_SIZES_ELEMENT, RECORD_MESSAGE_TIMES_ELEMENT, REDEPLOY_CHILDREN, REDEPLOY_ELEMENT, REF_ATTR, REF_NOT_FOUND, REF_NOT_FOUND_IN_CHANNEL, REF_NOT_FOUND_IN_DEST, REMOTE_ATTR, REQUEST_TIMEOUT_SECONDS_ELEMENT, REQUIRE_ADVANCED_MESSAGING_SUPPORT, ROLE_ELEMENT, ROLES_CHILDREN, ROLES_ELEMENT, SECURITY_CHILDREN, SECURITY_CONSTRAINT_ATTR, SECURITY_CONSTRAINT_DEFINITION_CHILDREN, SECURITY_CONSTRAINT_DEFINITION_ELEMENT, SECURITY_CONSTRAINT_ELEMENT, SECURITY_ELEMENT, SERIALIZATION_ELEMENT, SERVER_ATTR, SERVER_CHILDREN, SERVER_ELEMENT, SERVER_NAME_TOKEN, SERVER_ONLY_ATTR, SERVER_PORT_TOKEN, SERVER_REQ_CHILDREN, SERVERS_CHILDREN, SERVERS_ELEMENT, SERVICE_CHILDREN, SERVICE_ELEMENT, SERVICE_INCLUDE_CHILDREN, SERVICE_INCLUDE_ELEMENT, SERVICE_REQ_CHILDREN, SERVICES_CHILDREN, SERVICES_CONFIG_CHILDREN, SERVICES_CONFIG_ELEMENT, SERVICES_ELEMENT, SLASH_CONTEXT_PATH_TOKEN, SRC_ATTR, SYNC_MESSAGE_FILTERS_ELEMENT, SYNC_MESSAGE_FILTERS_ELEMENT_CHILDREN, SYSTEM_CHILDREN, SYSTEM_ELEMENT, TARGET_CHILDREN, TARGET_ELEMENT, TARGET_REQ_CHILDREN, TOO_MANY_OCCURRENCES, TOUCH_FILE_ELEMENT, TRUE_STRING, TYPE_ATTR, UNDEFINED_CONTEXT_ROOT, UNEXPECTED_ATTRIBUTE, UNEXPECTED_ELEMENT, UNEXPECTED_TEXT, UNKNOWN_SOURCE_FILE, UNREGISTERED_ADAPTER, URI_ATTR, URL_ATTR, VALIDATOR_CHILDREN, VALIDATOR_ELEMENT, VALIDATOR_REQ_CHILDREN, VALIDATORS_CHILDREN, VALIDATORS_ELEMENT, WATCH_FILE_ELEMENT, WATCH_INTERVAL_ELEMENT, XML_PARSER_ERROR
 
Constructor Summary
AsyncAMFEndpoint()
          Constructs an unmanaged AsyncAMFEndpoint.
AsyncAMFEndpoint(boolean enableManagement)
          Constructs an AsyncAMFEndpoint with the indicated management.
 
Method Summary
protected  flex.messaging.endpoints.amf.AMFFilter createFilterChain()
          Create the gateway filters that transform action requests and responses.
protected  java.lang.String getDeserializerClassName()
          Returns the deserializer class name used by the endpoint.
protected  java.lang.String getLogCategory()
          Returns the log category of the endpoint.
protected  java.lang.String getResponseContentType()
          Returns MessageIOConstants.AMF_CONTENT_TYPE.
protected  java.lang.String getSerializerClassName()
          Returns the serializer class name used by the endpoint.
protected  java.lang.String getSerializerJava15ClassName()
          Returns the Java 1.5 specific serializer class name used by the endpoint.
protected  void setupEndpointControl(flex.messaging.MessageBroker broker)
          Invoked automatically to allow the AsyncAMFEndpoint to setup its corresponding MBean control.
 
Methods inherited from class org.mortbay.jetty.asyncblazeds.BaseAsyncHTTPEndpoint
describeEndpoint, getClientWaitInterval, getMaxWaitingPollRequests, getWaitInterval, handleFlexClientPoll, initialize, service, setClientWaitInterval, setMaxWaitingPollRequests, setWaitInterval, start, stop, waitEnd, waitStart
 
Methods inherited from class flex.messaging.endpoints.BaseHTTPEndpoint
getInsecureProtocolScheme, getRedirectURL, getSecureProtocolScheme, handleChannelDisconnect, isAddNoCacheHeaders, isInvalidateSessionOnDisconnect, setAddNoCacheHeaders, setInvalidateSessionOnDisconnect, setRedirectURL, setupFlexClient
 
Methods inherited from class flex.messaging.endpoints.AbstractEndpoint
addClientLoadBalancingUrl, addNoCacheHeaders, checkSecurityConstraint, clearThreadLocals, convertToSmallMessage, createClass, getClientLoadBalancingUrls, getClientType, getFlexClientOutboundQueueProcessorClass, getFlexClientOutboundQueueProcessorConfig, getMessageBroker, getMessagingVersion, getParsedUrl, getPort, getSecurityConstraint, getSerializationContext, getServer, getServerOnly, getThroughput, getTypeMarshaller, getUrl, getUrlForClient, handleClientMessagingVersion, handleFlexClientPollCommand, initializeClientLoadBalancing, isRecordMessageSizes, isRecordMessageTimes, isRemote, isSecure, removeClientLoadBalancingUrl, serviceMessage, setClientType, setFlexClientOutboundQueueProcessorClass, setFlexClientOutboundQueueProcessorConfig, setId, setMessageBroker, setRemote, setSecurityConstraint, setSerializationContext, setServer, setServerOnly, setThreadLocals, setTypeMarshaller, setupFlexClient, setUrl, validateEndpointProtocol, validateRequestProtocol, verifyFlexClientSupport
 
Methods inherited from class flex.management.ManageableComponent
blockAssignmentWhileStarted, blockNullAssignment, getControl, getId, getParent, invalidate, isManaged, isStarted, isValid, setControl, setManaged, setParent, setStarted, setValid, validate
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface flex.messaging.endpoints.Endpoint
getId, isStarted
 
Methods inherited from interface flex.management.Manageable
getControl, isManaged, setControl, setManaged
 

Field Detail

LOG_CATEGORY

public static final java.lang.String LOG_CATEGORY
The log category for this endpoint.

See Also:
Constant Field Values
Constructor Detail

AsyncAMFEndpoint

public AsyncAMFEndpoint()
Constructs an unmanaged AsyncAMFEndpoint.


AsyncAMFEndpoint

public AsyncAMFEndpoint(boolean enableManagement)
Constructs an AsyncAMFEndpoint with the indicated management.

Parameters:
enableManagement - true if the AsyncAMFEndpoint is manageable; otherwise false.
Method Detail

createFilterChain

protected flex.messaging.endpoints.amf.AMFFilter createFilterChain()
Create the gateway filters that transform action requests and responses.

Specified by:
createFilterChain in class flex.messaging.endpoints.BaseHTTPEndpoint

getResponseContentType

protected java.lang.String getResponseContentType()
Returns MessageIOConstants.AMF_CONTENT_TYPE.

Specified by:
getResponseContentType in class flex.messaging.endpoints.BaseHTTPEndpoint
Returns:
MessageIOConstants.AMF_CONTENT_TYPE

getLogCategory

protected java.lang.String getLogCategory()
Returns the log category of the endpoint.

Overrides:
getLogCategory in class flex.messaging.endpoints.AbstractEndpoint
Returns:
The log category of the endpoint.

getDeserializerClassName

protected java.lang.String getDeserializerClassName()
Returns the deserializer class name used by the endpoint.

Specified by:
getDeserializerClassName in class flex.messaging.endpoints.AbstractEndpoint
Returns:
The deserializer class name used by the endpoint.

getSerializerClassName

protected java.lang.String getSerializerClassName()
Returns the serializer class name used by the endpoint.

Specified by:
getSerializerClassName in class flex.messaging.endpoints.AbstractEndpoint
Returns:
The serializer class name used by the endpoint.

getSerializerJava15ClassName

protected java.lang.String getSerializerJava15ClassName()
Returns the Java 1.5 specific serializer class name used by the endpoint.

Returns:
The Java 1.5 specific serializer class name used by the endpoint.

setupEndpointControl

protected void setupEndpointControl(flex.messaging.MessageBroker broker)
Invoked automatically to allow the AsyncAMFEndpoint to setup its corresponding MBean control.

Specified by:
setupEndpointControl in class flex.messaging.endpoints.AbstractEndpoint
Parameters:
broker - The MessageBroker that manages this AsyncAMFEndpoint.


Copyright © 1995-2011 Mort Bay Consulting. All Rights Reserved.