AccessRequestHandler.java
01 package org.apache.qpid.server.handler;
02 /*
03  
04  * Licensed to the Apache Software Foundation (ASF) under one
05  * or more contributor license agreements.  See the NOTICE file
06  * distributed with this work for additional information
07  * regarding copyright ownership.  The ASF licenses this file
08  * to you under the Apache License, Version 2.0 (the
09  * "License"); you may not use this file except in compliance
10  * with the License.  You may obtain a copy of the License at
11  
12  *   http://www.apache.org/licenses/LICENSE-2.0
13  
14  * Unless required by applicable law or agreed to in writing,
15  * software distributed under the License is distributed on an
16  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
17  * KIND, either express or implied.  See the License for the
18  * specific language governing permissions and limitations
19  * under the License.
20  
21  */
22 
23 
24 import org.apache.qpid.framing.*;
25 import org.apache.qpid.server.state.StateAwareMethodListener;
26 import org.apache.qpid.server.state.AMQStateManager;
27 import org.apache.qpid.server.protocol.AMQProtocolSession;
28 import org.apache.qpid.AMQException;
29 
30 /**
31  @author Apache Software Foundation
32  *
33  *
34  */
35 public class AccessRequestHandler implements StateAwareMethodListener<AccessRequestBody>
36 {
37     private static final AccessRequestHandler _instance = new AccessRequestHandler();
38 
39 
40     public static AccessRequestHandler getInstance()
41     {
42         return _instance;
43     }
44 
45     private AccessRequestHandler()
46     {
47     }
48 
49     public void methodReceived(AMQStateManager stateManager, AccessRequestBody body, int channelIdthrows AMQException
50     {
51         AMQProtocolSession session = stateManager.getProtocolSession();
52 
53         MethodRegistry methodRegistry = session.getMethodRegistry();
54 
55         // We don't implement access control class, but to keep clients happy that expect it
56         // always use the "0" ticket.
57         AccessRequestOkBody response = methodRegistry.createAccessRequestOkBody(0);
58 
59         session.writeFrame(response.generateFrame(channelId));
60     }
61 }