removing AMQProducer
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/0c8b1171 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/0c8b1171 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/0c8b1171 Branch: refs/heads/refactor-openwire Commit: 0c8b1171ac3c3e902958b2c78b7fa6bfe8dc8a86 Parents: fd52dc3 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Wed Feb 24 22:29:54 2016 -0500 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Thu Feb 25 18:10:23 2016 -0500 ---------------------------------------------------------------------- .../core/protocol/openwire/amq/AMQProducer.java | 38 -------------------- 1 file changed, 38 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/0c8b1171/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQProducer.java ---------------------------------------------------------------------- diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQProducer.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQProducer.java deleted file mode 100644 index 848325e..0000000 --- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQProducer.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF 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.activemq.artemis.core.protocol.openwire.amq; - -import org.apache.activemq.command.ProducerInfo; -import org.apache.activemq.artemis.core.protocol.openwire.OpenWireUtil; - -public class AMQProducer { - - private AMQSession amqSession; - private ProducerInfo info; - - public AMQProducer(AMQSession amqSession, ProducerInfo info) { - this.amqSession = amqSession; - this.info = info; - } - - public void init() throws Exception { - // If the destination is specified check that it exists. - if (info.getDestination() != null) { - OpenWireUtil.validateDestination(info.getDestination(), amqSession); - } - } -}
