activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From andytay...@apache.org
Subject [41/51] [abbrv] [partial] activemq-6 git commit: ACTIVEMQ6-4 - Rename packages to ActiveMQ
Date Tue, 11 Nov 2014 18:42:11 GMT
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/23e8edd9/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/ResourceNames.java
----------------------------------------------------------------------
diff --git a/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/ResourceNames.java b/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/ResourceNames.java
new file mode 100644
index 0000000..099038a
--- /dev/null
+++ b/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/ResourceNames.java
@@ -0,0 +1,56 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (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.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.apache.activemq6.api.core.management;
+
+/**
+ * Helper class used to build resource names used by management messages.
+ * <br>
+ * Resource's name is build by appending its <em>name</em> to its corresponding type.
+ * For example, the resource name of the "foo" queue is {@code CORE_QUEUE + "foo"}.
+ *
+ * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a>
+ */
+public final class ResourceNames
+{
+
+   public static final String CORE_SERVER = "core.server";
+
+   public static final String CORE_QUEUE = "core.queue.";
+
+   public static final String CORE_ADDRESS = "core.address.";
+
+   public static final String CORE_BRIDGE = "core.bridge.";
+
+   public static final String CORE_ACCEPTOR = "core.acceptor.";
+
+   public static final String CORE_DIVERT = "core.divert.";
+
+   public static final String CORE_CLUSTER_CONNECTION = "core.clusterconnection.";
+
+   public static final String CORE_BROADCAST_GROUP = "core.broadcastgroup.";
+
+   public static final String CORE_DISCOVERY_GROUP = "core.discovery.";
+
+   public static final String JMS_SERVER = "jms.server";
+
+   public static final String JMS_QUEUE = "jms.queue.";
+
+   public static final String JMS_TOPIC = "jms.topic.";
+
+   public static final String JMS_CONNECTION_FACTORY = "jms.connectionfactory.";
+
+   private ResourceNames()
+   {
+   }
+
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/23e8edd9/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/RoleInfo.java
----------------------------------------------------------------------
diff --git a/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/RoleInfo.java b/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/RoleInfo.java
new file mode 100644
index 0000000..f0070c9
--- /dev/null
+++ b/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/RoleInfo.java
@@ -0,0 +1,148 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (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.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.apache.activemq6.api.core.management;
+
+import org.apache.activemq6.utils.json.JSONArray;
+import org.apache.activemq6.utils.json.JSONObject;
+
+/**
+ * Helper class to create Java Objects from the
+ * JSON serialization returned by {@link AddressControl#getRolesAsJSON()}.
+ *
+ * @author <a href="jmesnil@redhat.com">Jeff Mesnil</a>
+ */
+public final class RoleInfo
+{
+   private final String name;
+
+   private final boolean send;
+
+   private final boolean consume;
+
+   private final boolean createDurableQueue;
+
+   private final boolean deleteDurableQueue;
+
+   private final boolean createNonDurableQueue;
+
+   private final boolean deleteNonDurableQueue;
+
+   private final boolean manage;
+
+   /**
+    * Returns an array of RoleInfo corresponding to the JSON serialization returned
+    * by {@link AddressControl#getRolesAsJSON()}.
+    */
+   public static RoleInfo[] from(final String jsonString) throws Exception
+   {
+      JSONArray array = new JSONArray(jsonString);
+      RoleInfo[] roles = new RoleInfo[array.length()];
+      for (int i = 0; i < array.length(); i++)
+      {
+         JSONObject r = array.getJSONObject(i);
+         RoleInfo role = new RoleInfo(r.getString("name"),
+                                      r.getBoolean("send"),
+                                      r.getBoolean("consume"),
+                                      r.getBoolean("createDurableQueue"),
+                                      r.getBoolean("deleteDurableQueue"),
+                                      r.getBoolean("createNonDurableQueue"),
+                                      r.getBoolean("deleteNonDurableQueue"),
+                                      r.getBoolean("manage"));
+         roles[i] = role;
+      }
+      return roles;
+   }
+
+   private RoleInfo(final String name,
+                    final boolean send,
+                    final boolean consume,
+                    final boolean createDurableQueue,
+                    final boolean deleteDurableQueue,
+                    final boolean createNonDurableQueue,
+                    final boolean deleteNonDurableQueue,
+                    final boolean manage)
+   {
+      this.name = name;
+      this.send = send;
+      this.consume = consume;
+      this.createDurableQueue = createDurableQueue;
+      this.deleteDurableQueue = deleteDurableQueue;
+      this.createNonDurableQueue = createNonDurableQueue;
+      this.deleteNonDurableQueue = deleteNonDurableQueue;
+      this.manage = manage;
+   }
+
+   /**
+    * Returns the name of the role.
+    */
+   public String getName()
+   {
+      return name;
+   }
+
+   /**
+    * Returns whether this role can send messages to the address.
+    */
+   public boolean isSend()
+   {
+      return send;
+   }
+
+   /**
+    * Returns whether this role can consume messages from queues bound to the address.
+    */
+   public boolean isConsume()
+   {
+      return consume;
+   }
+
+   /**
+    * Returns whether this role can create durable queues bound to the address.
+    */
+   public boolean isCreateDurableQueue()
+   {
+      return createDurableQueue;
+   }
+
+   /**
+    * Returns whether this role can delete durable queues bound to the address.
+    */
+   public boolean isDeleteDurableQueue()
+   {
+      return deleteDurableQueue;
+   }
+
+   /**
+    * Returns whether this role can create non-durable queues bound to the address.
+    */
+   public boolean isCreateNonDurableQueue()
+   {
+      return createNonDurableQueue;
+   }
+
+   /**
+    * Returns whether this role can delete non-durable queues bound to the address.
+    */
+   public boolean isDeleteNonDurableQueue()
+   {
+      return deleteNonDurableQueue;
+   }
+
+   /**
+    * Returns whether this role can send management messages to the address.
+    */
+   public boolean isManage()
+   {
+      return manage;
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/23e8edd9/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/package-info.java
----------------------------------------------------------------------
diff --git a/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/package-info.java b/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/package-info.java
new file mode 100644
index 0000000..75dfa6c
--- /dev/null
+++ b/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/management/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (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.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+/**
+ * Management API for HornetQ servers and its Core resources.
+ * <br>
+ * HornetQ can be managed either using JMX or by sending management messages to the
+ * server's special management address. Please refer to the user manual for more information.
+ */
+package org.apache.activemq6.api.core.management;
+

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/23e8edd9/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/package-info.java
----------------------------------------------------------------------
diff --git a/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/package-info.java b/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/package-info.java
new file mode 100644
index 0000000..8757bb2
--- /dev/null
+++ b/activemq6-core-client/src/main/java/org/apache/activemq6/api/core/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (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.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+/**
+ * Core Messaging API.
+ * <br>
+ * This package defines base classes and interfaces used
+ * throughout HornetQ API
+ */
+package org.apache.activemq6.api.core;
+

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/23e8edd9/activemq6-core-client/src/main/java/org/apache/activemq6/core/buffers/impl/ResetLimitWrappedHornetQBuffer.java
----------------------------------------------------------------------
diff --git a/activemq6-core-client/src/main/java/org/apache/activemq6/core/buffers/impl/ResetLimitWrappedHornetQBuffer.java b/activemq6-core-client/src/main/java/org/apache/activemq6/core/buffers/impl/ResetLimitWrappedHornetQBuffer.java
new file mode 100644
index 0000000..396ece6
--- /dev/null
+++ b/activemq6-core-client/src/main/java/org/apache/activemq6/core/buffers/impl/ResetLimitWrappedHornetQBuffer.java
@@ -0,0 +1,392 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (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.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.apache.activemq6.core.buffers.impl;
+
+import java.nio.ByteBuffer;
+
+import org.apache.activemq6.api.core.HornetQBuffer;
+import org.apache.activemq6.api.core.SimpleString;
+import org.apache.activemq6.core.message.impl.MessageInternal;
+
+/**
+ * A ResetLimitWrappedHornetQBuffer
+ * TODO: Move this to commons
+ * @author Tim Fox
+ *
+ */
+public final class ResetLimitWrappedHornetQBuffer extends ChannelBufferWrapper
+{
+   private final int limit;
+
+   private MessageInternal message;
+
+   /**
+    * We need to turn of notifications of body changes on reset on the server side when dealing with AMQP conversions,
+    * for that reason this method will set the message to null here
+    * @param message
+    */
+   public void setMessage(MessageInternal message)
+   {
+      this.message = message;
+   }
+
+   public ResetLimitWrappedHornetQBuffer(final int limit, final HornetQBuffer buffer, final MessageInternal message)
+   {
+      super(buffer.byteBuf());
+
+      this.limit = limit;
+
+      if (writerIndex() < limit)
+      {
+         writerIndex(limit);
+      }
+
+      buffer.readerIndex(limit);
+
+      this.message = message;
+   }
+
+   private void changed()
+   {
+      if (message != null)
+      {
+         message.bodyChanged();
+      }
+   }
+
+   public void setBuffer(final HornetQBuffer buffer)
+   {
+      if (this.buffer != null)
+      {
+         this.buffer.release();
+      }
+      this.buffer = buffer.byteBuf();
+   }
+
+   @Override
+   public void clear()
+   {
+      changed();
+
+      buffer.clear();
+
+      buffer.setIndex(limit, limit);
+
+   }
+
+   @Override
+   public void readerIndex(int readerIndex)
+   {
+      changed();
+
+      if (readerIndex < limit)
+      {
+         readerIndex = limit;
+      }
+
+      buffer.readerIndex(readerIndex);
+   }
+
+   @Override
+   public void resetReaderIndex()
+   {
+      changed();
+
+      buffer.readerIndex(limit);
+   }
+
+   @Override
+   public void resetWriterIndex()
+   {
+      changed();
+
+      buffer.writerIndex(limit);
+   }
+
+   @Override
+   public void setIndex(int readerIndex, int writerIndex)
+   {
+      changed();
+
+      if (readerIndex < limit)
+      {
+         readerIndex = limit;
+      }
+      if (writerIndex < limit)
+      {
+         writerIndex = limit;
+      }
+      buffer.setIndex(readerIndex, writerIndex);
+   }
+
+   @Override
+   public void writerIndex(int writerIndex)
+   {
+      changed();
+
+      if (writerIndex < limit)
+      {
+         writerIndex = limit;
+      }
+
+      buffer.writerIndex(writerIndex);
+   }
+
+   @Override
+   public void setByte(final int index, final byte value)
+   {
+      changed();
+
+      super.setByte(index, value);
+   }
+
+   @Override
+   public void setBytes(final int index, final byte[] src, final int srcIndex, final int length)
+   {
+      changed();
+
+      super.setBytes(index, src, srcIndex, length);
+   }
+
+   @Override
+   public void setBytes(final int index, final byte[] src)
+   {
+      changed();
+
+      super.setBytes(index, src);
+   }
+
+   @Override
+   public void setBytes(final int index, final ByteBuffer src)
+   {
+      changed();
+
+      super.setBytes(index, src);
+   }
+
+   @Override
+   public void setBytes(final int index, final HornetQBuffer src, final int srcIndex, final int length)
+   {
+      changed();
+
+      super.setBytes(index, src, srcIndex, length);
+   }
+
+   @Override
+   public void setBytes(final int index, final HornetQBuffer src, final int length)
+   {
+      changed();
+
+      super.setBytes(index, src, length);
+   }
+
+   @Override
+   public void setBytes(final int index, final HornetQBuffer src)
+   {
+      changed();
+
+      super.setBytes(index, src);
+   }
+
+   @Override
+   public void setChar(final int index, final char value)
+   {
+      changed();
+
+      super.setChar(index, value);
+   }
+
+   @Override
+   public void setDouble(final int index, final double value)
+   {
+      changed();
+
+      super.setDouble(index, value);
+   }
+
+   @Override
+   public void setFloat(final int index, final float value)
+   {
+      changed();
+
+      super.setFloat(index, value);
+   }
+
+   @Override
+   public void setInt(final int index, final int value)
+   {
+      changed();
+
+      super.setInt(index, value);
+   }
+
+   @Override
+   public void setLong(final int index, final long value)
+   {
+      changed();
+
+      super.setLong(index, value);
+   }
+
+   @Override
+   public void setShort(final int index, final short value)
+   {
+      changed();
+
+      super.setShort(index, value);
+   }
+
+   @Override
+   public void writeBoolean(final boolean val)
+   {
+      changed();
+
+      super.writeBoolean(val);
+   }
+
+   @Override
+   public void writeByte(final byte value)
+   {
+      changed();
+
+      super.writeByte(value);
+   }
+
+   @Override
+   public void writeBytes(final byte[] src, final int srcIndex, final int length)
+   {
+      changed();
+
+      super.writeBytes(src, srcIndex, length);
+   }
+
+   @Override
+   public void writeBytes(final byte[] src)
+   {
+      changed();
+
+      super.writeBytes(src);
+   }
+
+   @Override
+   public void writeBytes(final ByteBuffer src)
+   {
+      changed();
+
+      super.writeBytes(src);
+   }
+
+   @Override
+   public void writeBytes(final HornetQBuffer src, final int srcIndex, final int length)
+   {
+      changed();
+
+      super.writeBytes(src, srcIndex, length);
+   }
+
+   @Override
+   public void writeBytes(final HornetQBuffer src, final int length)
+   {
+      changed();
+
+      super.writeBytes(src, length);
+   }
+
+   @Override
+   public void writeChar(final char chr)
+   {
+      changed();
+
+      super.writeChar(chr);
+   }
+
+   @Override
+   public void writeDouble(final double value)
+   {
+      changed();
+
+      super.writeDouble(value);
+   }
+
+   @Override
+   public void writeFloat(final float value)
+   {
+      changed();
+
+      super.writeFloat(value);
+   }
+
+   @Override
+   public void writeInt(final int value)
+   {
+      changed();
+
+      super.writeInt(value);
+   }
+
+   @Override
+   public void writeLong(final long value)
+   {
+      changed();
+
+      super.writeLong(value);
+   }
+
+   @Override
+   public void writeNullableSimpleString(final SimpleString val)
+   {
+      changed();
+
+      super.writeNullableSimpleString(val);
+   }
+
+   @Override
+   public void writeNullableString(final String val)
+   {
+      changed();
+
+      super.writeNullableString(val);
+   }
+
+   @Override
+   public void writeShort(final short value)
+   {
+      changed();
+
+      super.writeShort(value);
+   }
+
+   @Override
+   public void writeSimpleString(final SimpleString val)
+   {
+      changed();
+
+      super.writeSimpleString(val);
+   }
+
+   @Override
+   public void writeString(final String val)
+   {
+      changed();
+
+      super.writeString(val);
+   }
+
+   @Override
+   public void writeUTF(final String utf)
+   {
+      changed();
+
+      super.writeUTF(utf);
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/23e8edd9/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/HornetQClientLogger.java
----------------------------------------------------------------------
diff --git a/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/HornetQClientLogger.java b/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/HornetQClientLogger.java
new file mode 100644
index 0000000..fcba4e1
--- /dev/null
+++ b/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/HornetQClientLogger.java
@@ -0,0 +1,415 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (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.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.apache.activemq6.core.client;
+
+import org.apache.activemq6.api.core.HornetQExceptionType;
+import org.apache.activemq6.api.core.Interceptor;
+import org.apache.activemq6.core.protocol.core.Packet;
+import org.jboss.logging.BasicLogger;
+import org.jboss.logging.Logger;
+import org.jboss.logging.annotations.Cause;
+import org.jboss.logging.annotations.LogMessage;
+import org.jboss.logging.annotations.Message;
+import org.jboss.logging.annotations.MessageLogger;
+import org.w3c.dom.Node;
+
+/**
+ * Logger Code 21
+ * <p>
+ * Each message id must be 6 digits long starting with 10, the 3rd digit donates the level so
+ *
+ * <pre>
+ * INF0  1
+ * WARN  2
+ * DEBUG 3
+ * ERROR 4
+ * TRACE 5
+ * FATAL 6
+ * </pre>
+ *
+ * so an INFO message would be 101000 to 101999.
+ * <p>
+ * Once released, methods should not be deleted as they may be referenced by knowledge base
+ * articles. Unused methods should be marked as deprecated.
+ *
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
+ */
+@MessageLogger(projectCode = "HQ")
+public interface HornetQClientLogger extends BasicLogger
+{
+   /**
+    * The default logger.
+    */
+   HornetQClientLogger LOGGER = Logger.getMessageLogger(HornetQClientLogger.class, HornetQClientLogger.class.getPackage().getName());
+
+   @LogMessage(level = Logger.Level.INFO)
+   @Message(id = 211000, value = "**** Dumping session creation stacks ****", format = Message.Format.MESSAGE_FORMAT)
+   void dumpingSessionStacks();
+
+   @LogMessage(level = Logger.Level.INFO)
+   @Message(id = 211001, value = "session created", format = Message.Format.MESSAGE_FORMAT)
+   void dumpingSessionStack(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212000, value = "{0}", format = Message.Format.MESSAGE_FORMAT)
+   void warn(String message);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212001, value = "Error on clearing messages", format = Message.Format.MESSAGE_FORMAT)
+   void errorClearingMessages(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212002, value = "Timed out waiting for handler to complete processing", format = Message.Format.MESSAGE_FORMAT)
+   void timeOutWaitingForProcessing();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212003, value = "Unable to close session", format = Message.Format.MESSAGE_FORMAT)
+   void unableToCloseSession(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212004, value = "Failed to connect to server.", format = Message.Format.MESSAGE_FORMAT)
+   void failedToConnectToServer();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212005, value = "Tried {0} times to connect. Now giving up on reconnecting it.", format = Message.Format.MESSAGE_FORMAT)
+   void failedToConnectToServer(Integer reconnectAttempts);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212006, value = "Waiting {0} milliseconds before next retry. RetryInterval={1} and multiplier={2}", format = Message.Format.MESSAGE_FORMAT)
+   void waitingForRetry(Long interval, Long retryInterval, Double multiplier);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212007,
+            value = "connector.create or connectorFactory.createConnector should never throw an exception, implementation is badly behaved, but we will deal with it anyway.",
+            format = Message.Format.MESSAGE_FORMAT)
+   void createConnectorException(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212008,
+            value = "I am closing a core ClientSessionFactory you left open. Please make sure you close all ClientSessionFactories explicitly "
+               + "before letting them go out of scope! {0}",
+            format = Message.Format.MESSAGE_FORMAT)
+   void factoryLeftOpen(@Cause Exception e, int i);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212009, value = "resetting session after failure", format = Message.Format.MESSAGE_FORMAT)
+   void resettingSessionAfterFailure();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212010, value = "Server is starting, retry to create the session {0}", format = Message.Format.MESSAGE_FORMAT)
+   void retryCreateSessionSeverStarting(String name);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212011, value = "committing transaction after failover occurred, any non persistent messages may be lost", format = Message.Format.MESSAGE_FORMAT)
+   void commitAfterFailover();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212012, value = "failover occurred during commit throwing XAException.XA_RETRY", format = Message.Format.MESSAGE_FORMAT)
+   void failoverDuringCommit();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212014, value = "failover occurred during prepare rolling back", format = Message.Format.MESSAGE_FORMAT)
+   void failoverDuringPrepareRollingBack();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212015, value = "failover occurred during prepare rolling back", format = Message.Format.MESSAGE_FORMAT)
+   void errorDuringPrepare(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212016,
+            value = "I am closing a core ClientSession you left open. Please make sure you close all ClientSessions explicitly before letting them go out of scope! {0}",
+            format = Message.Format.MESSAGE_FORMAT)
+   void clientSessionNotClosed(@Cause Exception e, int identity);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212017, value = "error adding packet", format = Message.Format.MESSAGE_FORMAT)
+   void errorAddingPacket(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212018, value = "error calling cancel", format = Message.Format.MESSAGE_FORMAT)
+   void errorCallingCancel(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212019, value = "error reading index", format = Message.Format.MESSAGE_FORMAT)
+   void errorReadingIndex(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212020, value = "error setting index", format = Message.Format.MESSAGE_FORMAT)
+   void errorSettingIndex(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212021, value = "error resetting index", format = Message.Format.MESSAGE_FORMAT)
+   void errorReSettingIndex(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212022, value = "error reading LargeMessage file cache", format = Message.Format.MESSAGE_FORMAT)
+   void errorReadingCache(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212023, value = "error closing LargeMessage file cache", format = Message.Format.MESSAGE_FORMAT)
+   void errorClosingCache(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212024, value = "Exception during finalization for LargeMessage file cache", format = Message.Format.MESSAGE_FORMAT)
+   void errorFinalisingCache(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212025, value = "did not connect the cluster connection to other nodes", format = Message.Format.MESSAGE_FORMAT)
+   void errorConnectingToNodes(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212026, value = "Timed out waiting for pool to terminate", format = Message.Format.MESSAGE_FORMAT)
+   void timedOutWaitingForTermination();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212027, value = "Timed out waiting for scheduled pool to terminate", format = Message.Format.MESSAGE_FORMAT)
+   void timedOutWaitingForScheduledPoolTermination();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212028, value = "error starting server locator", format = Message.Format.MESSAGE_FORMAT)
+   void errorStartingLocator(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212029,
+            value = "Closing a Server Locator left open. Please make sure you close all Server Locators explicitly before letting them go out of scope! {0}",
+            format = Message.Format.MESSAGE_FORMAT)
+   void serverLocatorNotClosed(@Cause Exception e, int identity);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212030, value = "error sending topology", format = Message.Format.MESSAGE_FORMAT)
+   void errorSendingTopology(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212031, value = "error sending topology", format = Message.Format.MESSAGE_FORMAT)
+   void errorSendingTopologyNodedown(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212032, value = "Timed out waiting to stop discovery thread", format = Message.Format.MESSAGE_FORMAT)
+   void timedOutStoppingDiscovery();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212033, value = "unable to send notification when discovery group is stopped", format = Message.Format.MESSAGE_FORMAT)
+   void errorSendingNotifOnDiscoveryStop(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212034,
+            value = "There are more than one servers on the network broadcasting the same node id. "
+               + "You will see this message exactly once (per node) if a node is restarted, in which case it can be safely "
+               + "ignored. But if it is logged continuously it means you really do have more than one node on the same network "
+               + "active concurrently with the same node id. This could occur if you have a backup node active at the same time as "
+               + "its live node. nodeID={0}",
+            format = Message.Format.MESSAGE_FORMAT)
+   void multipleServersBroadcastingSameNode(String nodeId);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212035, value = "error receiving packet in discovery", format = Message.Format.MESSAGE_FORMAT)
+   void errorReceivingPAcketInDiscovery(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212036,
+            value = "Can not find packet to clear: {0} last received command id first stored command id {1}",
+            format = Message.Format.MESSAGE_FORMAT)
+   void cannotFindPacketToClear(Integer lastReceivedCommandID, Integer firstStoredCommandID);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212037, value = "Connection failure has been detected: {0} [code={1}]", format = Message.Format.MESSAGE_FORMAT)
+   void connectionFailureDetected(String message, HornetQExceptionType type);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212038, value = "Failure in calling interceptor: {0}", format = Message.Format.MESSAGE_FORMAT)
+   void errorCallingInterceptor(@Cause Throwable e, Interceptor interceptor);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212040, value = "Timed out waiting for netty ssl close future to complete", format = Message.Format.MESSAGE_FORMAT)
+   void timeoutClosingSSL();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212041, value = "Timed out waiting for netty channel to close", format = Message.Format.MESSAGE_FORMAT)
+   void timeoutClosingNettyChannel();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212042, value = "Timed out waiting for packet to be flushed", format = Message.Format.MESSAGE_FORMAT)
+   void timeoutFlushingPacket();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212043, value = "Property {0} must be an Integer, it is {1}", format = Message.Format.MESSAGE_FORMAT)
+   void propertyNotInteger(String propName, String name);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212044, value = "Property {0} must be an Long, it is {1}", format = Message.Format.MESSAGE_FORMAT)
+   void propertyNotLong(String propName, String name);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212045, value = "Property {0} must be an Boolean, it is {1}", format = Message.Format.MESSAGE_FORMAT)
+   void propertyNotBoolean(String propName, String name);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212046, value = "Cannot find hornetq-version.properties on classpath: {0}",
+            format = Message.Format.MESSAGE_FORMAT)
+   void noVersionOnClasspath(String classpath);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212047, value = "Warning: JVM allocated more data what would make results invalid {0}:{1}", format = Message.Format.MESSAGE_FORMAT)
+   void jvmAllocatedMoreMemory(Long totalMemory1, Long totalMemory2);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212048, value = "local-bind-address specified for broadcast group but no local-bind-port specified so socket will NOT be bound to a local address/port",
+            format = Message.Format.MESSAGE_FORMAT)
+   void broadcastGroupBindError();
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212049,
+            value = "Could not bind to {0} ({1} address); " +
+               "make sure your discovery group-address is of the same type as the IP stack (IPv4 or IPv6)." +
+               "\nIgnoring discovery group-address, but this may lead to cross talking.",
+            format = Message.Format.MESSAGE_FORMAT)
+   void ioDiscoveryError(String hostAddress, String s);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212050, value = "Compressed large message tried to read {0} bytes from stream {1}",
+            format = Message.Format.MESSAGE_FORMAT)
+   void compressedLargeMessageError(int length, int nReadBytes);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212051,
+            value = "Invalid concurrent session usage. Sessions are not supposed to be used by more than one thread concurrently.",
+            format = Message.Format.MESSAGE_FORMAT)
+   void invalidConcurrentSessionUsage(@Cause Throwable t);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212052,
+            value = "Packet {0} was answered out of sequence due to a previous server timeout and it''s being ignored",
+            format = Message.Format.MESSAGE_FORMAT)
+   void packetOutOfOrder(Object obj, @Cause Throwable t);
+
+   /**
+    * Warns about usage of {@link org.apache.activemq6.api.core.client.SendAcknowledgementHandler} or JMS's {@code CompletionWindow} with
+    * confirmations disabled (confirmationWindowSize=-1).
+    */
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212053,
+            value = "CompletionListener/SendAcknowledgementHandler used with confirmationWindowSize=-1. Enable confirmationWindowSize to receive acks from server!",
+            format = Message.Format.MESSAGE_FORMAT)
+   void confirmationWindowDisabledWarning();
+
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212054,
+            value = "Destination address={0} is blocked. If the system is configured to block make sure you consume messages on this configuration.",
+            format = Message.Format.MESSAGE_FORMAT)
+   void outOfCreditOnFlowControl(String address);
+
+   @LogMessage(level = Logger.Level.WARN)
+   @Message(id = 212055, value = "Unable to close consumer", format = Message.Format.MESSAGE_FORMAT)
+   void unableToCloseConsumer(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214000, value = "Failed to call onMessage", format = Message.Format.MESSAGE_FORMAT)
+   void onMessageError(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214001, value = "failed to cleanup session", format = Message.Format.MESSAGE_FORMAT)
+   void failedToCleanupSession(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214002, value = "Failed to execute failure listener", format = Message.Format.MESSAGE_FORMAT)
+   void failedToExecuteListener(@Cause Throwable t);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214003, value = "Failed to handle failover", format = Message.Format.MESSAGE_FORMAT)
+   void failedToHandleFailover(@Cause Throwable t);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214004, value = "XA end operation failed ", format = Message.Format.MESSAGE_FORMAT)
+   void errorCallingEnd(@Cause Throwable t);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214005, value = "XA start operation failed {0} code:{1}", format = Message.Format.MESSAGE_FORMAT)
+   void errorCallingStart(String message, Integer code);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214006, value = "Session is not XA", format = Message.Format.MESSAGE_FORMAT)
+   void sessionNotXA();
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214007, value = "Received exception asynchronously from server", format = Message.Format.MESSAGE_FORMAT)
+   void receivedExceptionAsynchronously(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214008, value = "Failed to handle packet", format = Message.Format.MESSAGE_FORMAT)
+   void failedToHandlePacket(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214009, value = "Failed to stop discovery group", format = Message.Format.MESSAGE_FORMAT)
+   void failedToStopDiscovery(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214010, value = "Failed to receive datagram", format = Message.Format.MESSAGE_FORMAT)
+   void failedToReceiveDatagramInDiscovery(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214011, value = "Failed to call discovery listener", format = Message.Format.MESSAGE_FORMAT)
+   void failedToCallListenerInDiscovery(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214012, value = "Unexpected error handling packet {0}", format = Message.Format.MESSAGE_FORMAT)
+   void errorHandlingPacket(@Cause Throwable t, Packet packet);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214013, value = "Failed to decode packet", format = Message.Format.MESSAGE_FORMAT)
+   void errorDecodingPacket(@Cause Exception e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214014, value = "Failed to execute failure listener", format = Message.Format.MESSAGE_FORMAT)
+   void errorCallingFailureListener(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214015, value = "Failed to execute connection life cycle listener", format = Message.Format.MESSAGE_FORMAT)
+   void errorCallingLifeCycleListener(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214016, value = "Failed to create netty connection", format = Message.Format.MESSAGE_FORMAT)
+   void errorCreatingNettyConnection(@Cause Throwable e);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214017, value = "Caught unexpected Throwable", format = Message.Format.MESSAGE_FORMAT)
+   void caughtunexpectedThrowable(@Cause Throwable t);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214018, value = "Failed to invoke getTextContent() on node {0}", format = Message.Format.MESSAGE_FORMAT)
+   void errorOnXMLTransform(@Cause Throwable t, Node n);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214019, value = "Invalid configuration", format = Message.Format.MESSAGE_FORMAT)
+   void errorOnXMLTransformInvalidConf(@Cause Throwable t);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214020, value = "Exception happened while stopping Discovery BroadcastEndpoint {0}", format = Message.Format.MESSAGE_FORMAT)
+   void errorStoppingDiscoveryBroadcastEndpoint(Object endpoint, @Cause Throwable t);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214021, value = "Invalid cipher suite specified. Supported cipher suites are: {0}", format = Message.Format.MESSAGE_FORMAT)
+   void invalidCipherSuite(String validSuites);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214022, value = "Invalid protocol specified. Supported protocols are: {0}", format = Message.Format.MESSAGE_FORMAT)
+   void invalidProtocol(String validProtocols);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214023, value = "HTTP Handshake failed, the received accept value %s does not match the expected response %s")
+   void httpHandshakeFailed(String response, String expectedResponse);
+
+   @LogMessage(level = Logger.Level.ERROR)
+   @Message(id = 214024, value = "HTTP upgrade not supported by remote acceptor")
+   void httpUpgradeNotSupportedByRemoteAcceptor();
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/23e8edd9/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/HornetQClientMessageBundle.java
----------------------------------------------------------------------
diff --git a/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/HornetQClientMessageBundle.java b/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/HornetQClientMessageBundle.java
new file mode 100644
index 0000000..1d4fc5c
--- /dev/null
+++ b/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/HornetQClientMessageBundle.java
@@ -0,0 +1,247 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (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.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq6.core.client;
+
+
+import org.apache.activemq6.api.core.HornetQAddressFullException;
+import org.apache.activemq6.api.core.HornetQConnectionTimedOutException;
+import org.apache.activemq6.api.core.HornetQDisconnectedException;
+import org.apache.activemq6.api.core.HornetQIllegalStateException;
+import org.apache.activemq6.api.core.HornetQInterceptorRejectedPacketException;
+import org.apache.activemq6.api.core.HornetQInternalErrorException;
+import org.apache.activemq6.api.core.HornetQLargeMessageException;
+import org.apache.activemq6.api.core.HornetQLargeMessageInterruptedException;
+import org.apache.activemq6.api.core.HornetQNotConnectedException;
+import org.apache.activemq6.api.core.HornetQObjectClosedException;
+import org.apache.activemq6.api.core.HornetQTransactionOutcomeUnknownException;
+import org.apache.activemq6.api.core.HornetQTransactionRolledBackException;
+import org.apache.activemq6.api.core.HornetQUnBlockedException;
+import org.apache.activemq6.core.cluster.DiscoveryGroup;
+import org.apache.activemq6.spi.core.remoting.Connection;
+import org.jboss.logging.annotations.Cause;
+import org.jboss.logging.annotations.Message;
+import org.jboss.logging.annotations.MessageBundle;
+import org.jboss.logging.Messages;
+import org.w3c.dom.Node;
+
+/**
+ * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
+ *         3/12/12
+ *
+ * Logger Code 11
+ *
+ * each message id must be 6 digits long starting with 10, the 3rd digit should be 9
+ *
+ * so 119000 to 119999
+ */
+@MessageBundle(projectCode = "HQ")
+public interface HornetQClientMessageBundle
+{
+   HornetQClientMessageBundle BUNDLE = Messages.getBundle(HornetQClientMessageBundle.class);
+
+   @Message(id = 119000, value = "ClientSession closed while creating session", format = Message.Format.MESSAGE_FORMAT)
+   HornetQInternalErrorException clientSessionClosed();
+
+   @Message(id = 119001, value = "Failed to create session", format = Message.Format.MESSAGE_FORMAT)
+   HornetQInternalErrorException failedToCreateSession(@Cause Throwable t);
+
+   @Message(id = 119002, value = "Internal Error! ClientSessionFactoryImpl::createSessionInternal "
+                                          + "just reached a condition that was not supposed to happen. "
+                                      + "Please inform this condition to the HornetQ team", format = Message.Format.MESSAGE_FORMAT)
+   HornetQInternalErrorException clietSessionInternal();
+
+   @Message(id = 119003, value = "Queue can not be both durable and temporary", format = Message.Format.MESSAGE_FORMAT)
+   HornetQInternalErrorException queueMisConfigured();
+
+   @Message(id = 119004, value = "Failed to initialise session factory", format = Message.Format.MESSAGE_FORMAT)
+   HornetQInternalErrorException failedToInitialiseSessionFactory(@Cause Exception e);
+
+   @Message(id = 119005, value = "Exception in Netty transport", format = Message.Format.MESSAGE_FORMAT)
+   HornetQInternalErrorException nettyError();
+
+   @Message(id = 119006, value =  "Channel disconnected", format = Message.Format.MESSAGE_FORMAT)
+   HornetQNotConnectedException channelDisconnected();
+
+   @Message(id = 119007, value =  "Cannot connect to server(s). Tried with all available servers.", format = Message.Format.MESSAGE_FORMAT)
+   HornetQNotConnectedException cannotConnectToServers();
+
+   @Message(id = 119008, value =  "Failed to connect to any static connectors", format = Message.Format.MESSAGE_FORMAT)
+   HornetQNotConnectedException cannotConnectToStaticConnectors(@Cause Exception e);
+
+   @Message(id = 119009, value =  "Failed to connect to any static connectors", format = Message.Format.MESSAGE_FORMAT)
+   HornetQNotConnectedException cannotConnectToStaticConnectors2();
+
+   @Message(id = 119010, value =  "Connection is destroyed", format = Message.Format.MESSAGE_FORMAT)
+   HornetQNotConnectedException connectionDestroyed();
+
+   @Message(id = 119011, value =  "Did not receive data from server for {0}", format = Message.Format.MESSAGE_FORMAT)
+   HornetQConnectionTimedOutException connectionTimedOut(Connection transportConnection);
+
+   @Message(id = 119012, value =  "Timed out waiting to receive initial broadcast from cluster", format = Message.Format.MESSAGE_FORMAT)
+   HornetQConnectionTimedOutException connectionTimedOutInInitialBroadcast();
+
+   @Message(id = 119013, value =  "Timed out waiting to receive cluster topology. Group:{0}", format = Message.Format.MESSAGE_FORMAT)
+   HornetQConnectionTimedOutException connectionTimedOutOnReceiveTopology(DiscoveryGroup discoveryGroup);
+
+   @Message(id = 119014, value =  "Timed out waiting for response when sending packet {0}", format = Message.Format.MESSAGE_FORMAT)
+   HornetQConnectionTimedOutException timedOutSendingPacket(Byte type);
+
+   @Message(id = 119015, value =  "The connection was disconnected because of server shutdown", format = Message.Format.MESSAGE_FORMAT)
+   HornetQDisconnectedException disconnected();
+
+   @Message(id = 119016, value =  "Connection failure detected. Unblocking a blocking call that will never get a resp" +
+         "onse", format = Message.Format.MESSAGE_FORMAT)
+   HornetQUnBlockedException unblockingACall(@Cause Throwable t);
+
+   @Message(id = 119017, value =  "Consumer is closed", format = Message.Format.MESSAGE_FORMAT)
+   HornetQObjectClosedException consumerClosed();
+
+   @Message(id = 119018, value =  "Producer is closed", format = Message.Format.MESSAGE_FORMAT)
+   HornetQObjectClosedException producerClosed();
+
+   @Message(id = 119019, value =  "Session is closed", format = Message.Format.MESSAGE_FORMAT)
+   HornetQObjectClosedException sessionClosed();
+
+   @Message(id = 119020, value =  "Cannot call receive(...) - a MessageHandler is set", format = Message.Format.MESSAGE_FORMAT)
+   HornetQIllegalStateException messageHandlerSet();
+
+   @Message(id = 119021, value =  "Cannot set MessageHandler - consumer is in receive(...)", format = Message.Format.MESSAGE_FORMAT)
+   HornetQIllegalStateException inReceive();
+
+   @Message(id = 119022, value =  "Header size ({0}) is too big, use the messageBody for large data, or increase minLargeMessageSize",
+         format = Message.Format.MESSAGE_FORMAT)
+   HornetQIllegalStateException headerSizeTooBig(Integer headerSize);
+
+   @Message(id = 119023, value =  "The large message lost connection with its session, either because of a rollback or a closed session", format = Message.Format.MESSAGE_FORMAT)
+   HornetQIllegalStateException largeMessageLostSession();
+
+   @Message(id = 119024, value =  "Could not select a TransportConfiguration to create SessionFactory", format = Message.Format.MESSAGE_FORMAT)
+   HornetQIllegalStateException noTCForSessionFactory();
+
+   @Message(id = 119025, value = "Error saving the message body", format = Message.Format.MESSAGE_FORMAT)
+   HornetQLargeMessageException errorSavingBody(@Cause Exception e);
+
+   @Message(id = 119026, value =  "Error reading the LargeMessageBody", format = Message.Format.MESSAGE_FORMAT)
+   HornetQLargeMessageException errorReadingBody(@Cause Exception e);
+
+   @Message(id = 119027, value =  "Error closing stream from LargeMessageBody", format = Message.Format.MESSAGE_FORMAT)
+   HornetQLargeMessageException errorClosingLargeMessage(@Cause Exception e);
+
+   @Message(id = 119028, value =  "Timeout waiting for LargeMessage Body", format = Message.Format.MESSAGE_FORMAT)
+   HornetQLargeMessageException timeoutOnLargeMessage();
+
+   @Message(id = 119029, value =  "Error writing body of message", format = Message.Format.MESSAGE_FORMAT)
+   HornetQLargeMessageException errorWritingLargeMessage(@Cause Exception e);
+
+   @Message(id = 119030, value =  "The transaction was rolled back on failover to a backup server", format = Message.Format.MESSAGE_FORMAT)
+   HornetQTransactionRolledBackException txRolledBack();
+
+   @Message(id = 119031, value =  "The transaction was rolled back on failover however commit may have been successful" +
+         "", format = Message.Format.MESSAGE_FORMAT)
+   HornetQTransactionOutcomeUnknownException txOutcomeUnknown();
+
+   @Message(id = 119032, value = "Invalid type: {0}", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException invalidType(Object type);
+
+   @Message(id = 119033, value = "Invalid type: {0}", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException invalidEncodeType(Object type);
+
+   @Message(id = 119034, value = "Params for management operations must be of the following type: int long double String boolean Map or array thereof but found {0}",
+         format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException invalidManagementParam(Object type);
+
+   @Message(id = 119035, value = "Invalid window size {0}", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException invalidWindowSize(Integer size);
+
+   @Message(id = 119036, value = "No operation mapped to int {0}", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException noOperationMapped(Integer operation);
+
+   @Message(id = 119037, value = "Invalid last Received Command ID: {0}", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException invalidCommandID(Integer lastReceivedCommandID);
+
+   @Message(id = 119038, value = "Cannot find channel with id {0} to close", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException noChannelToClose(Long id);
+
+   @Message(id = 119039, value = "Close Listener cannot be null", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException closeListenerCannotBeNull();
+
+   @Message(id = 119040, value = "Fail Listener cannot be null", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException failListenerCannotBeNull();
+
+   @Message(id = 119041, value = "Connection already exists with id {0}", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException connectionExists(Object id);
+
+   @Message(id = 119042, value = "Invalid argument null listener", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException nullListener();
+
+   @Message(id = 119043, value = "Invalid argument null handler", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException nullHandler();
+
+   @Message(id = 119044, value = "No available codec to decode password!", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException noCodec();
+
+   @Message(id = 119045, value = "the first node to be compared is null", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException firstNodeNull();
+
+   @Message(id = 119046, value = "the second node to be compared is null", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException secondNodeNull();
+
+   @Message(id = 119047, value = "nodes have different node names", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException nodeHaveDifferentNames();
+
+   @Message(id = 119048, value = "nodes hava a different number of attributes", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException nodeHaveDifferentAttNumber();
+
+   @Message(id = 119049, value = "attribute {0}={1} does not match", format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException attsDontMatch(String name, String value);
+
+   @Message(id = 119050, value = "one node has children and the other does not" , format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException oneNodeHasChildren();
+
+   @Message(id = 119051, value = "nodes hava a different number of children" , format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException nodeHasDifferentChildNumber();
+
+   @Message(id = 119052, value = "Element {0} requires a valid Boolean value, but ''{1}'' cannot be parsed as a Boolean" , format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException mustBeBoolean(Node elem, String value);
+
+   @Message(id = 119053, value = "Element {0} requires a valid Double value, but ''{1}'' cannot be parsed as a Double" , format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException mustBeDouble(Node elem, String value);
+
+   @Message(id = 119054, value = "Element {0} requires a valid Integer value, but ''{1}'' cannot be parsed as a Integer" , format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException mustBeInteger(Node elem, String value);
+
+   @Message(id = 119055, value = "Element {0} requires a valid Long value, but ''{1}'' cannot be parsed as a Long" , format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException mustBeLong(Node elem, String value);
+
+   @Message(id = 119056, value = "Failed to get decoder" , format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException failedToGetDecoder(@Cause Exception e);
+
+   @Message(id = 119057, value = "Error decoding password" , format = Message.Format.MESSAGE_FORMAT)
+   IllegalArgumentException errordecodingPassword(@Cause Exception e);
+
+   @Message(id = 119058, value = "Address \"{0}\" is full. Message encode size = {1}B", format = Message.Format.MESSAGE_FORMAT)
+   HornetQAddressFullException addressIsFull(String addressName, int size);
+
+   @Message(id = 119059, value = "Interceptor {0} rejected packet in a blocking call. This call will never complete."
+         , format = Message.Format.MESSAGE_FORMAT)
+   HornetQInterceptorRejectedPacketException interceptorRejectedPacket(String interceptionResult);
+
+   @Message(id = 119060, value = "Large Message Transmission interrupted on consumer shutdown."
+         , format = Message.Format.MESSAGE_FORMAT)
+   HornetQLargeMessageInterruptedException largeMessageInterrupted();
+
+   @Message(id = 119061, value =  "error decoding AMQP frame", format = Message.Format.MESSAGE_FORMAT)
+   String decodeError();
+
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/23e8edd9/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/impl/AddressQueryImpl.java
----------------------------------------------------------------------
diff --git a/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/impl/AddressQueryImpl.java b/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/impl/AddressQueryImpl.java
new file mode 100644
index 0000000..00dd51d
--- /dev/null
+++ b/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/impl/AddressQueryImpl.java
@@ -0,0 +1,44 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (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.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+package org.apache.activemq6.core.client.impl;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.apache.activemq6.api.core.SimpleString;
+import org.apache.activemq6.api.core.client.ClientSession;
+
+public class AddressQueryImpl implements ClientSession.AddressQuery, ClientSession.BindingQuery
+{
+
+   private final boolean exists;
+
+   private final ArrayList<SimpleString> queueNames;
+
+   public AddressQueryImpl(final boolean exists, final List<SimpleString> queueNames)
+   {
+      this.exists = exists;
+      this.queueNames = new ArrayList<SimpleString>(queueNames);
+   }
+
+   public List<SimpleString> getQueueNames()
+   {
+      return queueNames;
+   }
+
+   public boolean isExists()
+   {
+      return exists;
+   }
+}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/23e8edd9/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/impl/AfterConnectInternalListener.java
----------------------------------------------------------------------
diff --git a/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/impl/AfterConnectInternalListener.java b/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/impl/AfterConnectInternalListener.java
new file mode 100644
index 0000000..d1ca8dd
--- /dev/null
+++ b/activemq6-core-client/src/main/java/org/apache/activemq6/core/client/impl/AfterConnectInternalListener.java
@@ -0,0 +1,27 @@
+/*
+ * Copyright 2005-2014 Red Hat, Inc.
+ * Red Hat licenses this file to you under the Apache License, version
+ * 2.0 (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.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ * implied.  See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+package org.apache.activemq6.core.client.impl;
+
+/**
+ * To be called right after the ConnectionFactory created a connection.
+ * This listener is not part of the API and shouldn't be used by users.
+ * (if you do so we can't guarantee any API compatibility on this class)
+ *
+ * @author clebertsuconic
+ *
+ *
+ */
+public interface AfterConnectInternalListener
+{
+   void onConnection(ClientSessionFactoryInternal sf);
+}


Mime
View raw message