- private static final int MESSAGE_LENGTH = 16;
-
- private static GetQueueConfigInputMessageFactory instance;
-
-
- private GetQueueConfigInputMessageFactory() {
- // singleton
- }
-
-
- /**
- * @return singleton factory
- */
- public static GetQueueConfigInputMessageFactory getInstance(){
-
- if(instance == null){
- instance = new GetQueueConfigInputMessageFactory();
- }
-
- return instance;
- }
-
- @Override
- public void messageToBuffer(short version, ByteBuf out, GetQueueConfigInput message){
- ByteBufUtils.writeOFHeader(instance, message, out);
- out.writeInt(message.getPort().getValue().intValue());
- ByteBufUtils.padBuffer(PADDING_IN_GET_QUEUE_CONFIG_MESSAGE, out);
- }