AccessRequestOkMethodHandler.java
01 package org.apache.qpid.client.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.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
26 
27 import org.apache.qpid.framing.*;
28 import org.apache.qpid.client.state.StateAwareMethodListener;
29 import org.apache.qpid.client.protocol.AMQProtocolSession;
30 import org.apache.qpid.AMQException;
31 
32 public class AccessRequestOkMethodHandler implements StateAwareMethodListener<AccessRequestOkBody>
33 {
34     private static final Logger _logger = LoggerFactory.getLogger(AccessRequestOkMethodHandler.class);
35 
36     private static AccessRequestOkMethodHandler _handler = new AccessRequestOkMethodHandler();
37 
38     public static AccessRequestOkMethodHandler getInstance()
39     {
40         return _handler;
41     }
42 
43     public void methodReceived(AMQProtocolSession session, AccessRequestOkBody method, int channelId)
44         throws AMQException
45     {
46         _logger.debug("AccessRequestOk method received");
47         session.setTicket(method.getTicket(), channelId);
48 
49     }
50 }