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-2011 VMware, Inc.  All rights reserved.
 //
 
 
 package com.rabbitmq.client.impl;
 
 import java.util.Date;
 import java.util.Map;
 
Generates an AMQP wire-protocol packet from a com.rabbitmq.client.ContentHeader. Methods on this object are usually called from autogenerated code.
 
 public class ContentHeaderPropertyWriter {
    
Accumulates our output
 
     private final ValueWriter out;

    
Current flags word being accumulated
 
     public int flagWord;

    
Position within current flags word
 
     public int bitCount;

    
Constructs a fresh ContentHeaderPropertyWriter.
 
         this. = new ValueWriter(out);
         this. = 0;
         this. = 0;
     }
 
     private void emitFlagWord(boolean continuationBitthrows IOException {
         .writeShort(continuationBit ? ( | 1) : );
          = 0;
          = 0;
     }
 
     public void writePresence(boolean presentthrows IOException {
         if ( == 15) {
             emitFlagWord(true);
         }
 
         if (present) {
             int bit = 15 - ;
              =  | (1 << bit);
         }
         ++;
     }
 
     public void finishPresence() throws IOException {
         emitFlagWord(false);
     }
 
     public void writeShortstr(String strthrows IOException {
         .writeShortstr(str);
     }
 
     public void writeLongstr(String strthrows IOException {
         .writeLongstr(str);
     }
 
     public void writeLongstr(LongString strthrows IOException {
         .writeLongstr(str);
     }
 
     public void writeShort(Integer sthrows IOException {
         .writeShort(s);
     }
 
     public void writeLong(Integer lthrows IOException {
         .writeLong(l);
     }
 
     public void writeLonglong(Long llthrows IOException {
         .writeLonglong(ll);
     }
 
     public void writeTable(Map<StringObjecttablethrows IOException {
         .writeTable(table);
     }
    public void writeOctet(Integer octetthrows IOException {
        .writeOctet(octet);
    }
    public void writeOctet(int octetthrows IOException {
        .writeOctet(octet);
    }
    public void writeTimestamp(Date timestampthrows IOException {
        .writeTimestamp(timestamp);
    }
New to GrepCode? Check out our FAQ X