diff options
Diffstat (limited to 'plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal')
5 files changed, 0 insertions, 236 deletions
diff --git a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/JMSAdmin.java b/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/JMSAdmin.java deleted file mode 100644 index 4b7dbe4522..0000000000 --- a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/JMSAdmin.java +++ /dev/null @@ -1,60 +0,0 @@ -/*************************************************************************** - * Copyright (c) 2004 - 2008 Eike Stepper, Germany. - * 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: - * Eike Stepper - initial API and implementation - **************************************************************************/ -package org.eclipse.net4j.jms.internal.admin; - -import org.eclipse.net4j.channel.IChannel; -import org.eclipse.net4j.connector.IConnector; -import org.eclipse.net4j.jms.JMSAdminProtocolConstants; -import org.eclipse.net4j.jms.admin.IJMSAdmin; -import org.eclipse.net4j.jms.internal.admin.bundle.OM; -import org.eclipse.net4j.jms.internal.admin.protocol.JMSCreateDestinationRequest; - -/** - * @author Eike Stepper - */ -public class JMSAdmin implements IJMSAdmin -{ - private IChannel channel; - - public JMSAdmin(IConnector connector) - { - channel = connector.openChannel(JMSAdminProtocolConstants.PROTOCOL_NAME, this); - } - - public void close() - { - channel.close(); - channel = null; - } - - public boolean createQueue(String name) - { - return createDestination(name, JMSAdminProtocolConstants.DESTINATION_TYPE_QUEUE); - } - - public boolean createTopic(String name) - { - return createDestination(name, JMSAdminProtocolConstants.DESTINATION_TYPE_TOPIC); - } - - private boolean createDestination(String name, byte type) - { - try - { - return new JMSCreateDestinationRequest(channel, type, name).send(); - } - catch (Exception ex) - { - OM.LOG.error(ex); - return false; - } - } -} diff --git a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/bundle/OM.java b/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/bundle/OM.java deleted file mode 100644 index 1b5dfd2b05..0000000000 --- a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/bundle/OM.java +++ /dev/null @@ -1,46 +0,0 @@ -/*************************************************************************** - * Copyright (c) 2004 - 2008 Eike Stepper, Germany. - * 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: - * Eike Stepper - initial API and implementation - **************************************************************************/ -package org.eclipse.net4j.jms.internal.admin.bundle; - -import org.eclipse.net4j.util.om.OMBundle; -import org.eclipse.net4j.util.om.OMPlatform; -import org.eclipse.net4j.util.om.OSGiActivator; -import org.eclipse.net4j.util.om.log.OMLogger; -import org.eclipse.net4j.util.om.trace.OMTracer; - -/** - * The <em>Operations & Maintenance</em> class of this bundle. - * - * @author Eike Stepper - */ -public abstract class OM -{ - public static final String BUNDLE_ID = "org.eclipse.net4j.jms.admin"; //$NON-NLS-1$ - - public static final OMBundle BUNDLE = OMPlatform.INSTANCE.bundle(BUNDLE_ID, OM.class); - - public static final OMTracer DEBUG = BUNDLE.tracer("debug"); //$NON-NLS-1$ - - public static final OMTracer DEBUG_PROTOCOL = DEBUG.tracer("protocol"); //$NON-NLS-1$ - - public static final OMLogger LOG = BUNDLE.logger(); - - /** - * @author Eike Stepper - */ - public static final class Activator extends OSGiActivator - { - public Activator() - { - super(BUNDLE); - } - } -} diff --git a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/protocol/JMSAdminProtocol.java b/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/protocol/JMSAdminProtocol.java deleted file mode 100644 index f5f0d2a891..0000000000 --- a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/protocol/JMSAdminProtocol.java +++ /dev/null @@ -1,36 +0,0 @@ -/*************************************************************************** - * Copyright (c) 2004 - 2008 Eike Stepper, Germany. - * 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: - * Eike Stepper - initial API and implementation - **************************************************************************/ -package org.eclipse.net4j.jms.internal.admin.protocol; - -import org.eclipse.net4j.jms.JMSAdminProtocolConstants; -import org.eclipse.net4j.signal.SignalProtocol; -import org.eclipse.net4j.signal.SignalReactor; - -/** - * @author Eike Stepper - */ -public class JMSAdminProtocol extends SignalProtocol -{ - public JMSAdminProtocol() - { - } - - public String getType() - { - return JMSAdminProtocolConstants.PROTOCOL_NAME; - } - - @Override - protected SignalReactor doCreateSignalReactor(short signalID) - { - return null; - } -} diff --git a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/protocol/JMSAdminProtocolFactory.java b/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/protocol/JMSAdminProtocolFactory.java deleted file mode 100644 index b725a9b946..0000000000 --- a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/protocol/JMSAdminProtocolFactory.java +++ /dev/null @@ -1,39 +0,0 @@ -/*************************************************************************** - * Copyright (c) 2004 - 2008 Eike Stepper, Germany. - * 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: - * Eike Stepper - initial API and implementation - **************************************************************************/ -package org.eclipse.net4j.jms.internal.admin.protocol; - -import org.eclipse.net4j.jms.JMSAdminProtocolConstants; -import org.eclipse.net4j.util.container.IManagedContainer; - -import org.eclipse.internal.net4j.protocol.ClientProtocolFactory; - -/** - * @author Eike Stepper - */ -public final class JMSAdminProtocolFactory extends ClientProtocolFactory -{ - public static final String TYPE = JMSAdminProtocolConstants.PROTOCOL_NAME; - - public JMSAdminProtocolFactory() - { - super(TYPE); - } - - public JMSAdminProtocol create(String description) - { - return new JMSAdminProtocol(); - } - - public static JMSAdminProtocol get(IManagedContainer container, String description) - { - return (JMSAdminProtocol)container.getElement(PRODUCT_GROUP, TYPE, description); - } -} diff --git a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/protocol/JMSCreateDestinationRequest.java b/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/protocol/JMSCreateDestinationRequest.java deleted file mode 100644 index 513cbe58ee..0000000000 --- a/plugins/org.eclipse.net4j.jms.admin/src/org/eclipse/net4j/jms/internal/admin/protocol/JMSCreateDestinationRequest.java +++ /dev/null @@ -1,55 +0,0 @@ -/*************************************************************************** - * Copyright (c) 2004 - 2008 Eike Stepper, Germany. - * 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: - * Eike Stepper - initial API and implementation - **************************************************************************/ -package org.eclipse.net4j.jms.internal.admin.protocol; - -import org.eclipse.net4j.channel.IChannel; -import org.eclipse.net4j.jms.JMSAdminProtocolConstants; -import org.eclipse.net4j.signal.RequestWithConfirmation; -import org.eclipse.net4j.util.io.ExtendedDataInputStream; -import org.eclipse.net4j.util.io.ExtendedDataOutputStream; - -import java.io.IOException; - -/** - * @author Eike Stepper - */ -public class JMSCreateDestinationRequest extends RequestWithConfirmation<Boolean> -{ - private byte type; - - private String name; - - public JMSCreateDestinationRequest(IChannel channel, byte type, String name) - { - super(channel); - this.type = type; - this.name = name; - } - - @Override - protected short getSignalID() - { - return JMSAdminProtocolConstants.SIGNAL_CREATE_DESTINATION; - } - - @Override - protected void requesting(ExtendedDataOutputStream out) throws IOException - { - out.writeByte(type); - out.writeString(name); - } - - @Override - protected Boolean confirming(ExtendedDataInputStream in) throws IOException - { - return in.readBoolean(); - } -} |