diff options
Diffstat (limited to 'plugins/org.eclipse.net4j.jms.server')
14 files changed, 115 insertions, 40 deletions
diff --git a/plugins/org.eclipse.net4j.jms.server/META-INF/MANIFEST.MF b/plugins/org.eclipse.net4j.jms.server/META-INF/MANIFEST.MF index 678ebf4c85..09a9e3be1c 100644 --- a/plugins/org.eclipse.net4j.jms.server/META-INF/MANIFEST.MF +++ b/plugins/org.eclipse.net4j.jms.server/META-INF/MANIFEST.MF @@ -14,6 +14,7 @@ Require-Bundle: org.eclipse.core.runtime;bundle-version="[3.4.0,4.0.0)", Import-Package: javax.jms;version="1.1.0" Export-Package: org.eclipse.net4j.jms.internal.server;version="2.0.0";x-friends:="org.eclipse.net4j.jms.server.jdbc,org.eclipse.net4j.jms.tests", org.eclipse.net4j.jms.internal.server.bundle;version="2.0.0";x-internal:=true, + org.eclipse.net4j.jms.internal.server.messages;x-internal:=true, org.eclipse.net4j.jms.internal.server.protocol;version="2.0.0";x-friends:="org.eclipse.net4j.jms.server.jdbc,org.eclipse.net4j.jms.tests", org.eclipse.net4j.jms.internal.server.protocol.admin;version="2.0.0";x-friends:="org.eclipse.net4j.jms.server.jdbc,org.eclipse.net4j.jms.tests", org.eclipse.net4j.jms.internal.server.store;version="2.0.0";x-friends:="org.eclipse.net4j.jms.server.jdbc,org.eclipse.net4j.jms.tests", diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/Server.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/Server.java index 5818b566ce..e190359051 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/Server.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/Server.java @@ -14,6 +14,7 @@ import org.eclipse.net4j.internal.jms.ConnectionFactoryImpl; import org.eclipse.net4j.internal.jms.JMSDestination; import org.eclipse.net4j.internal.jms.MessageImpl; import org.eclipse.net4j.jms.internal.server.bundle.OM; +import org.eclipse.net4j.jms.internal.server.messages.Messages; import org.eclipse.net4j.jms.server.IDestination; import org.eclipse.net4j.jms.server.IServer; import org.eclipse.net4j.jms.server.IStore; @@ -75,7 +76,7 @@ public class Server extends QueueWorker<MessageImpl> implements IServer ServerDestination existing = destinations.putIfAbsent(name, destination); if (existing != null) { - throw new IllegalStateException("Destination " + type + " " + name + " does already exist"); + throw new IllegalStateException("Destination " + type + " " + name + " does already exist"); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ } IStoreTransaction transaction = store.startTransaction(); @@ -107,7 +108,7 @@ public class Server extends QueueWorker<MessageImpl> implements IServer ServerDestination destination = destinations.get(name); if (destination == null) { - OM.LOG.error("Invalid destination: " + name); + OM.LOG.error(Messages.getString("Server.3") + name); //$NON-NLS-1$ return null; } @@ -158,7 +159,7 @@ public class Server extends QueueWorker<MessageImpl> implements IServer return null; } - messageIDs[i] = "ID:NET4J:" + HexUtil.longToHex(messageIDCounter.increment()); + messageIDs[i] = "ID:NET4J:" + HexUtil.longToHex(messageIDCounter.increment()); //$NON-NLS-1$ message.setJMSMessageID(messageIDs[i]); } @@ -174,7 +175,7 @@ public class Server extends QueueWorker<MessageImpl> implements IServer @Override protected String getThreadName() { - return "jms-server"; + return "jms-server"; //$NON-NLS-1$ } @Override @@ -192,7 +193,7 @@ public class Server extends QueueWorker<MessageImpl> implements IServer super.doBeforeActivate(); if (store == null) { - throw new IllegalStateException("store == null"); + throw new IllegalStateException("store == null"); //$NON-NLS-1$ } } @@ -200,9 +201,9 @@ public class Server extends QueueWorker<MessageImpl> implements IServer protected void doActivate() throws Exception { super.doActivate(); - String name = System.getProperty("net4j.jms.connection.factory.name", "net4j.jms.ConnectionFactory"); - String type = System.getProperty("net4j.jms.connector.type", "tcp"); - String desc = System.getProperty("net4j.jms.connector.description", "localhost"); + String name = System.getProperty("net4j.jms.connection.factory.name", "net4j.jms.ConnectionFactory"); //$NON-NLS-1$ //$NON-NLS-2$ + String type = System.getProperty("net4j.jms.connector.type", "tcp"); //$NON-NLS-1$ //$NON-NLS-2$ + String desc = System.getProperty("net4j.jms.connector.description", "localhost"); //$NON-NLS-1$ //$NON-NLS-2$ jndiContext = new InitialContext(); jndiContext.rebind(name, new ConnectionFactoryImpl(type, desc)); diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/ServerConsumer.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/ServerConsumer.java index 8d5129201c..b3f454ca21 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/ServerConsumer.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/ServerConsumer.java @@ -122,7 +122,7 @@ public class ServerConsumer implements IServerConsumer for (MessageImpl message : messages.values()) { transaction.messageAcknowledged(message, id); - IOUtil.OUT().println("\nMessage acknowledged: " + message.getJMSMessageID() + " (consumer=" + id + ")\n"); + IOUtil.OUT().println("\nMessage acknowledged: " + message.getJMSMessageID() + " (consumer=" + id + ")\n"); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ } messages.clear(); @@ -140,7 +140,7 @@ public class ServerConsumer implements IServerConsumer for (MessageImpl message : messages.values()) { - IOUtil.OUT().println("\nRecovering message: " + message.getJMSMessageID() + " (consumer=" + id + ")\n"); + IOUtil.OUT().println("\nRecovering message: " + message.getJMSMessageID() + " (consumer=" + id + ")\n"); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ session.getConnection().getServer().addWork(message); } } diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/ServerSession.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/ServerSession.java index acaabd42c3..e99d284097 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/ServerSession.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/ServerSession.java @@ -13,11 +13,13 @@ package org.eclipse.net4j.jms.internal.server; import org.eclipse.net4j.internal.jms.DestinationImpl; import org.eclipse.net4j.internal.jms.MessageImpl; import org.eclipse.net4j.jms.internal.server.bundle.OM; +import org.eclipse.net4j.jms.internal.server.messages.Messages; import org.eclipse.net4j.jms.server.ISession; import org.eclipse.net4j.jms.server.IStore; import org.eclipse.net4j.jms.server.IStoreTransaction; import org.eclipse.net4j.util.lifecycle.Lifecycle; +import java.text.MessageFormat; import java.util.Collection; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; @@ -56,7 +58,7 @@ public class ServerSession extends Lifecycle implements ISession ServerDestination destination = server.getDestination(name); if (destination == null) { - OM.LOG.error("Destination not found: " + name); + OM.LOG.error(MessageFormat.format(Messages.getString("ServerSession_0"), name)); //$NON-NLS-1$ return -1; } diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/messages/Messages.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/messages/Messages.java new file mode 100644 index 0000000000..e3bf8d40e2 --- /dev/null +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/messages/Messages.java @@ -0,0 +1,41 @@ +/** + * Copyright (c) 2004 - 2009 Eike Stepper (Berlin, Germany) and others. + * All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 + * which accompanies this distribution, and is available at + * http://www.eclipse.org/legal/epl-v10.html + * + * Contributors: + * Victor Roldan Betancort - initial API and implementation + * Eike Stepper - maintenance + */ +package org.eclipse.net4j.jms.internal.server.messages; + +import java.util.MissingResourceException; +import java.util.ResourceBundle; + +/** + * @author Victor Roldan Betancort + */ +public class Messages +{ + private static final String BUNDLE_NAME = "org.eclipse.net4j.jms.internal.server.messages.messages"; //$NON-NLS-1$ + + private static final ResourceBundle RESOURCE_BUNDLE = ResourceBundle.getBundle(BUNDLE_NAME); + + private Messages() + { + } + + public static String getString(String key) + { + try + { + return RESOURCE_BUNDLE.getString(key); + } + catch (MissingResourceException e) + { + return '!' + key + '!'; + } + } +} diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/messages/messages.properties b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/messages/messages.properties new file mode 100644 index 0000000000..0a197e736f --- /dev/null +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/messages/messages.properties @@ -0,0 +1,17 @@ +# Copyright (c) 2004 - 2009 Eike Stepper (Berlin, Germany) and others. +# All rights reserved. This program and the accompanying materials +# are made available under the terms of the Eclipse Public License v1.0 +# which accompanies this distribution, and is available at +# http://www.eclipse.org/legal/epl-v10.html +# +# Contributors: +# Victor Roldan Betancort - initial API and implementation +# Eike Stepper - maintenance + +JMSAcknowledgeIndication_0=Session {0} not found. Acknowledgement discarded. +JMSCommitIndication_0=Session {0} not found +JMSLogonIndication_0=Access to JMS server denied +JMSRecoverIndication_0=Session {0} not found +JMSRollbackIndication_0=Session {0} not found +Server.3=Invalid destination: +ServerSession_0=Destination not found: {0} diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSAcknowledgeIndication.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSAcknowledgeIndication.java index 8a919ac00b..0365d3a4d0 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSAcknowledgeIndication.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSAcknowledgeIndication.java @@ -14,9 +14,12 @@ import org.eclipse.net4j.jms.JMSProtocolConstants; import org.eclipse.net4j.jms.internal.server.ServerConnection; import org.eclipse.net4j.jms.internal.server.ServerSession; import org.eclipse.net4j.jms.internal.server.bundle.OM; +import org.eclipse.net4j.jms.internal.server.messages.Messages; import org.eclipse.net4j.signal.Indication; import org.eclipse.net4j.util.io.ExtendedDataInputStream; +import java.text.MessageFormat; + /** * @author Eike Stepper */ @@ -37,7 +40,7 @@ public class JMSAcknowledgeIndication extends Indication ServerSession session = connection.getSession(sessionID); if (session == null) { - OM.LOG.info("Session " + sessionID + " not found. Acknowledgement discarded."); + OM.LOG.info(MessageFormat.format(Messages.getString("JMSAcknowledgeIndication_0"), sessionID)); //$NON-NLS-1$ return; } diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSCommitIndication.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSCommitIndication.java index f7133a7d4d..c1fbde0101 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSCommitIndication.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSCommitIndication.java @@ -16,10 +16,13 @@ import org.eclipse.net4j.jms.JMSProtocolConstants; import org.eclipse.net4j.jms.internal.server.ServerConnection; import org.eclipse.net4j.jms.internal.server.ServerSession; import org.eclipse.net4j.jms.internal.server.bundle.OM; +import org.eclipse.net4j.jms.internal.server.messages.Messages; import org.eclipse.net4j.signal.IndicationWithResponse; import org.eclipse.net4j.util.io.ExtendedDataInputStream; import org.eclipse.net4j.util.io.ExtendedDataOutputStream; +import java.text.MessageFormat; + /** * @author Eike Stepper */ @@ -48,7 +51,7 @@ public class JMSCommitIndication extends IndicationWithResponse ServerSession session = connection.getSession(sessionID); if (session == null) { - OM.LOG.warn("Session " + sessionID + " not found"); + OM.LOG.warn(MessageFormat.format(Messages.getString("JMSCommitIndication_0"), sessionID)); //$NON-NLS-1$ return; } diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSLogonIndication.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSLogonIndication.java index b9e4fcdaad..a98d43805e 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSLogonIndication.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSLogonIndication.java @@ -14,6 +14,7 @@ import org.eclipse.net4j.jms.JMSProtocolConstants; import org.eclipse.net4j.jms.internal.server.Server; import org.eclipse.net4j.jms.internal.server.ServerConnection; import org.eclipse.net4j.jms.internal.server.bundle.OM; +import org.eclipse.net4j.jms.internal.server.messages.Messages; import org.eclipse.net4j.signal.IndicationWithResponse; import org.eclipse.net4j.util.io.ExtendedDataInputStream; import org.eclipse.net4j.util.io.ExtendedDataOutputStream; @@ -38,7 +39,7 @@ public class JMSLogonIndication extends IndicationWithResponse ServerConnection connection = Server.INSTANCE.logon(userName, password); if (connection == null) { - OM.LOG.error("Access to JMS server denied"); + OM.LOG.error(Messages.getString("JMSLogonIndication_0")); //$NON-NLS-1$ return; } diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSRecoverIndication.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSRecoverIndication.java index 19ab251771..598ac37a65 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSRecoverIndication.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSRecoverIndication.java @@ -14,10 +14,13 @@ import org.eclipse.net4j.jms.JMSProtocolConstants; import org.eclipse.net4j.jms.internal.server.ServerConnection; import org.eclipse.net4j.jms.internal.server.ServerSession; import org.eclipse.net4j.jms.internal.server.bundle.OM; +import org.eclipse.net4j.jms.internal.server.messages.Messages; import org.eclipse.net4j.signal.IndicationWithResponse; import org.eclipse.net4j.util.io.ExtendedDataInputStream; import org.eclipse.net4j.util.io.ExtendedDataOutputStream; +import java.text.MessageFormat; + /** * @author Eike Stepper */ @@ -37,7 +40,7 @@ public class JMSRecoverIndication extends IndicationWithResponse ServerSession session = connection.getSession(sessionID); if (session == null) { - OM.LOG.warn("Session " + sessionID + " not found"); + OM.LOG.warn(MessageFormat.format(Messages.getString("JMSRecoverIndication_0"), sessionID)); //$NON-NLS-1$ return; } diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSRollbackIndication.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSRollbackIndication.java index 019698727e..63492b63e0 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSRollbackIndication.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/JMSRollbackIndication.java @@ -14,10 +14,13 @@ import org.eclipse.net4j.jms.JMSProtocolConstants; import org.eclipse.net4j.jms.internal.server.ServerConnection; import org.eclipse.net4j.jms.internal.server.ServerSession; import org.eclipse.net4j.jms.internal.server.bundle.OM; +import org.eclipse.net4j.jms.internal.server.messages.Messages; import org.eclipse.net4j.signal.IndicationWithResponse; import org.eclipse.net4j.util.io.ExtendedDataInputStream; import org.eclipse.net4j.util.io.ExtendedDataOutputStream; +import java.text.MessageFormat; + /** * @author Eike Stepper */ @@ -37,7 +40,7 @@ public class JMSRollbackIndication extends IndicationWithResponse ServerSession session = connection.getSession(sessionID); if (session == null) { - OM.LOG.warn("Session " + sessionID + " not found"); + OM.LOG.warn(MessageFormat.format(Messages.getString("JMSRollbackIndication_0"), sessionID)); //$NON-NLS-1$ return; } diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/admin/JMSCreateDestinationIndication.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/admin/JMSCreateDestinationIndication.java index 18a5aa11be..75fb005d6b 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/admin/JMSCreateDestinationIndication.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/protocol/admin/JMSCreateDestinationIndication.java @@ -60,6 +60,6 @@ public class JMSCreateDestinationIndication extends IndicationWithResponse return IDestination.Type.TOPIC; } - throw new IllegalArgumentException("type: " + type); + throw new IllegalArgumentException("type: " + type); //$NON-NLS-1$ } } diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/store/AbstractTransaction.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/store/AbstractTransaction.java index 77e821272f..09b2e8e014 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/store/AbstractTransaction.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/store/AbstractTransaction.java @@ -48,13 +48,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Getting destination names"); + TRACER.trace("Getting destination names"); //$NON-NLS-1$ } String[] names = doGetDestinationNames(); if (TRACER.isEnabled()) { - TRACER.trace("Got destination names " + names); + TRACER.trace("Got destination names " + names); //$NON-NLS-1$ } return names; @@ -64,13 +64,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Getting destination " + name); + TRACER.trace("Getting destination " + name); //$NON-NLS-1$ } ServerDestination destination = doGetDestination(name); if (TRACER.isEnabled()) { - TRACER.trace("Got destination " + destination); + TRACER.trace("Got destination " + destination); //$NON-NLS-1$ } return destination; @@ -80,13 +80,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Getting consumer IDs"); + TRACER.trace("Getting consumer IDs"); //$NON-NLS-1$ } long[] ids = doGetConsumerIDs(); if (TRACER.isEnabled()) { - TRACER.trace("Got consumer IDs " + ids); + TRACER.trace("Got consumer IDs " + ids); //$NON-NLS-1$ } return ids; @@ -96,13 +96,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Getting consumer " + id); + TRACER.trace("Getting consumer " + id); //$NON-NLS-1$ } ServerConsumer consumer = doGetConsumer(id); if (TRACER.isEnabled()) { - TRACER.trace("Got consumer " + consumer); + TRACER.trace("Got consumer " + consumer); //$NON-NLS-1$ } return consumer; @@ -112,13 +112,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Adding destination " + destination); + TRACER.trace("Adding destination " + destination); //$NON-NLS-1$ } doDestinationAdded((ServerDestination)destination); if (TRACER.isEnabled()) { - TRACER.trace("Added destination " + destination); + TRACER.trace("Added destination " + destination); //$NON-NLS-1$ } } @@ -126,13 +126,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Removing destination " + destination); + TRACER.trace("Removing destination " + destination); //$NON-NLS-1$ } doDestinationRemoved((ServerDestination)destination); if (TRACER.isEnabled()) { - TRACER.trace("Removed destination " + destination); + TRACER.trace("Removed destination " + destination); //$NON-NLS-1$ } } @@ -140,13 +140,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Adding consumer " + consumer); + TRACER.trace("Adding consumer " + consumer); //$NON-NLS-1$ } doConsumerAdded((ServerConsumer)consumer); if (TRACER.isEnabled()) { - TRACER.trace("Added consumer " + consumer); + TRACER.trace("Added consumer " + consumer); //$NON-NLS-1$ } } @@ -154,13 +154,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Removing consumer " + consumer); + TRACER.trace("Removing consumer " + consumer); //$NON-NLS-1$ } doConsumerRemoved((ServerConsumer)consumer); if (TRACER.isEnabled()) { - TRACER.trace("Removed consumer " + consumer); + TRACER.trace("Removed consumer " + consumer); //$NON-NLS-1$ } } @@ -168,13 +168,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Logging received message " + message); + TRACER.trace("Logging received message " + message); //$NON-NLS-1$ } doMessageReceived((MessageImpl)message); if (TRACER.isEnabled()) { - TRACER.trace("Logged received message " + message); + TRACER.trace("Logged received message " + message); //$NON-NLS-1$ } } @@ -182,13 +182,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Logging sent message " + message); + TRACER.trace("Logging sent message " + message); //$NON-NLS-1$ } doMessageSent((MessageImpl)message, consumerID); if (TRACER.isEnabled()) { - TRACER.trace("Logged sent message " + message); + TRACER.trace("Logged sent message " + message); //$NON-NLS-1$ } } @@ -196,13 +196,13 @@ public abstract class AbstractTransaction implements IStoreTransaction { if (TRACER.isEnabled()) { - TRACER.trace("Logging acknowledged message " + message); + TRACER.trace("Logging acknowledged message " + message); //$NON-NLS-1$ } doMessageAcknowledged((MessageImpl)message, consumerID); if (TRACER.isEnabled()) { - TRACER.trace("Logged acknowledged message " + message); + TRACER.trace("Logged acknowledged message " + message); //$NON-NLS-1$ } } diff --git a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/store/NOOPStore.java b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/store/NOOPStore.java index fc149c064e..083d917127 100644 --- a/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/store/NOOPStore.java +++ b/plugins/org.eclipse.net4j.jms.server/src/org/eclipse/net4j/jms/internal/server/store/NOOPStore.java @@ -17,7 +17,7 @@ import org.eclipse.net4j.jms.server.IStoreTransaction; */ public class NOOPStore extends AbstractStore { - private static final String STORE_TYPE = "NOOP"; + private static final String STORE_TYPE = "NOOP"; //$NON-NLS-1$ public NOOPStore() { |