Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  //  The contents of this file are subject to the Mozilla Public License
  //  Version 1.1 (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.mozilla.org/MPL/
  //
  //  Software distributed under the License is distributed on an "AS IS"
  //  basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
  //  the License for the specific language governing rights and
  //  limitations under the License.
 //
 //  The Original Code is RabbitMQ.
 //
 //  The Initial Developer of the Original Code is VMware, Inc.
 //  Copyright (c) 2007-2012 VMware, Inc.  All rights reserved.
 //
 
 
 package com.rabbitmq.client.impl;
 
 import java.util.Date;
 import java.util.Map;
 
Parses an AMQP wire-protocol com.rabbitmq.client.ContentHeader from a DataInputStream. Methods on this object are usually called from autogenerated code.
 
 public class ContentHeaderPropertyReader {
    
Stream we are reading from
 
     private final ValueReader in;

    
Current field flag word
 
     public int flagWord;

    
Current flag position counter
 
     public int bitCount;

    
Protected API - Constructs a reader from the given input stream
 
     public ContentHeaderPropertyReader(DataInputStream inthrows IOException {
         this. = new ValueReader(in);
         this. = 1; // just the continuation bit
         this. = 15; // forces a flagWord read
     }
 
     private boolean isContinuationBitSet() {
         return ( & 1) != 0;
     }
 
     public void readFlagWord() throws IOException {
         if (!isContinuationBitSet()) {
             // FIXME: Proper exception class!
             throw new IOException("Attempted to read flag word when none advertised");
         }
          = .readShort();
          = 0;
     }
 
     public boolean readPresence() throws IOException {
         if ( == 15) {
             readFlagWord();
         }
 
         int bit = 15 - ;
         ++;
         return ( & (1 << bit)) != 0;
     }
 
     public void finishPresence() throws IOException {
         if (isContinuationBitSet()) {
             // FIXME: Proper exception class!
             throw new IOException("Unexpected continuation flag word");
         }
     }

    
Reads and returns an AMQP short string content header field.
 
     public String readShortstr() throws IOException {
         return .readShortstr();
     }

    
Reads and returns an AMQP "long string" (binary) content header field.
 
     public LongString readLongstr() throws IOException {
         return .readLongstr();
     }

    
Reads and returns an AMQP short integer content header field.
 
     public Integer readShort() throws IOException {
         return .readShort();
     }

    
Reads and returns an AMQP integer content header field.
 
     public Integer readLong() throws IOException {
         return .readLong();
    }

    
Reads and returns an AMQP long integer content header field.
    public Long readLonglong() throws IOException {
        return .readLonglong();
    }

    
Reads and returns an AMQP table content header field.
    public Map<StringObjectreadTable() throws IOException {
        return .readTable();
    }

    
Reads and returns an AMQP octet content header field.
    public int readOctet() throws IOException {
        return .readOctet();
    }

    
Reads and returns an AMQP timestamp content header field.
    public Date readTimestamp() throws IOException {
        return .readTimestamp();
    }
New to GrepCode? Check out our FAQ X