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:[email protected]";>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="[email protected]">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:[email protected]";>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:[email protected]";>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); +}
