org.mortbay.jetty.asyncblazeds
Class AsyncHTTPEndpoint

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.AsyncHTTPEndpoint
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 AsyncHTTPEndpoint
extends BaseAsyncHTTPEndpoint


Field Summary
static java.lang.String LOG_CATEGORY
           
 
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
AsyncHTTPEndpoint()
          Constructs an unmanaged AsyncHTTPEndpoint.
AsyncHTTPEndpoint(boolean enableManagement)
          Constructs a AsyncHTTPEndpoint with the indicated management.
 
Method Summary
 flex.messaging.messages.Message convertToSmallMessage(flex.messaging.messages.Message message)
          Currently this override is a no-op to disable small messages over HTTP endpoints.
protected  flex.messaging.endpoints.amf.AMFFilter createFilterChain()
          Create default filter chain or return current one if already present.
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.XML_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 AsyncHTTPEndpoint 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, 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
See Also:
Constant Field Values
Constructor Detail

AsyncHTTPEndpoint

public AsyncHTTPEndpoint()
Constructs an unmanaged AsyncHTTPEndpoint.


AsyncHTTPEndpoint

public AsyncHTTPEndpoint(boolean enableManagement)
Constructs a AsyncHTTPEndpoint with the indicated management.

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

convertToSmallMessage

public flex.messaging.messages.Message convertToSmallMessage(flex.messaging.messages.Message message)
Currently this override is a no-op to disable small messages over HTTP endpoints.

Overrides:
convertToSmallMessage in class flex.messaging.endpoints.AbstractEndpoint

createFilterChain

protected flex.messaging.endpoints.amf.AMFFilter createFilterChain()
Create default filter chain or return current one if already present.

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

getResponseContentType

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

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

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 AsyncHTTPEndpoint to setup its corresponding MBean control.

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


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