/* * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. * */ package org.apache.qpid.server.protocol; import javax.security.sasl.SaslServer; import org.apache.qpid.AMQException; import org.apache.qpid.common.ClientProperties; import org.apache.qpid.framing.*; import org.apache.qpid.AMQConnectionException; import org.apache.qpid.protocol.AMQVersionAwareProtocolSession; import org.apache.qpid.server.AMQChannel; import org.apache.qpid.server.logging.RootMessageLogger; import org.apache.qpid.server.logging.LogActor; import org.apache.qpid.server.output.ProtocolOutputConverter; import org.apache.qpid.server.virtualhost.VirtualHost; import java.security.Principal; public interface AMQProtocolSession extends AMQVersionAwareProtocolSession { long getSessionID(); LogActor getLogActor(); public static final class ProtocolSessionIdentifier { private final Object _sessionIdentifier; private final Object _sessionInstance; ProtocolSessionIdentifier(AMQProtocolSession session) { _sessionIdentifier = session.getClientIdentifier(); _sessionInstance = session.getClientProperties() == null ? null : session.getClientProperties().getObject(ClientProperties.instance.toAMQShortString()); } public Object getSessionIdentifier() { return _sessionIdentifier; } public Object getSessionInstance() { return _sessionInstance; } } public static interface Task { public void doTask(AMQProtocolSession session) throws AMQException; } /** * Called when a protocol data block is received * * @param message the data block that has been received * * @throws Exception if processing the datablock fails */ void dataBlockReceived(AMQDataBlock message) throws Exception; /** * Get the context key associated with this session. Context key is described in the AMQ protocol specification (RFC * 6). * * @return the context key */ AMQShortString getContextKey(); /** * Set the context key associated with this session. Context key is described in the AMQ protocol specification (RFC * 6). * * @param contextKey the context key */ void setContextKey(AMQShortString contextKey); /** * Get the channel for this session associated with the specified id. A channel id is unique per connection (i.e. * per session). * * @param channelId the channel id which must be valid * * @return null if no channel exists, the channel otherwise */ AMQChannel getChannel(int channelId) throws AMQException; /** * Associate a channel with this session. * * @param channel the channel to associate with this session. It is an error to associate the same channel with more * than one session but this is not validated. */ void addChannel(AMQChannel channel) throws AMQException; /** * Close a specific channel. This will remove any resources used by the channel, including: