001 /** 002 * 003 * Copyright 2004 Protique Ltd 004 * 005 * Licensed under the Apache License, Version 2.0 (the "License"); 006 * you may not use this file except in compliance with the License. 007 * You may obtain a copy of the License at 008 * 009 * http://www.apache.org/licenses/LICENSE-2.0 010 * 011 * Unless required by applicable law or agreed to in writing, software 012 * distributed under the License is distributed on an "AS IS" BASIS, 013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 014 * See the License for the specific language governing permissions and 015 * limitations under the License. 016 * 017 **/ 018 019 020 package org.activemq.io.impl; 021 import java.io.DataInput; 022 import java.io.IOException; 023 024 import org.activemq.message.CleanupConnectionInfo; 025 import org.activemq.message.Packet; 026 027 /** 028 * Reads a ConsumerInfo object from a Stream 029 */ 030 031 public class CleanupConnectionInfoReader extends AbstractPacketReader { 032 033 /** 034 * Return the type of Packet 035 * 036 * @return integer representation of the type of Packet 037 */ 038 039 public int getPacketType() { 040 return Packet.CLEANUP_CONNECTION_INFO; 041 } 042 043 /** 044 * @return a new Packet instance 045 */ 046 047 public Packet createPacket() { 048 return new CleanupConnectionInfo(); 049 } 050 051 052 /** 053 * build a Packet instance from the data input stream 054 * 055 * @param packet A Packet object 056 * @param dataIn the data input stream to build the packet from 057 * @throws IOException 058 */ 059 060 public void buildPacket(Packet packet, DataInput dataIn) throws IOException { 061 super.buildPacket(packet, dataIn); 062 CleanupConnectionInfo info = (CleanupConnectionInfo) packet; 063 info.setClientId(dataIn.readUTF()); 064 info.setSessionId(dataIn.readShort()); 065 } 066 067 068 }