AMQP-26 removed the 'otp' package
This commit is contained in:
2
pom.xml
2
pom.xml
@@ -4,7 +4,7 @@
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<groupId>org.springframework.amqp</groupId>
|
||||
<artifactId>spring-amqp</artifactId>
|
||||
<name>Spring AMQP</name>
|
||||
<name>Spring AMQP Project</name>
|
||||
<version>1.0.0.BUILD-SNAPSHOT</version>
|
||||
<packaging>pom</packaging>
|
||||
<modules>
|
||||
|
||||
@@ -9,7 +9,7 @@
|
||||
</parent>
|
||||
<artifactId>spring-amqp-core</artifactId>
|
||||
<packaging>jar</packaging>
|
||||
<name>Spring AMQP Core</name>
|
||||
<name>Spring AMQP Abstraction Layer</name>
|
||||
<dependencies>
|
||||
<!-- Spring -->
|
||||
<dependency>
|
||||
|
||||
@@ -13,7 +13,7 @@
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.springframework.otp.erlang;
|
||||
package org.springframework.erlang;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpErlangTuple;
|
||||
|
||||
@@ -13,7 +13,7 @@
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.springframework.otp.erlang;
|
||||
package org.springframework.erlang;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpErlangTuple;
|
||||
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang;
|
||||
package org.springframework.erlang;
|
||||
|
||||
/**
|
||||
* Runtime exception mirroring the OTP OtpAuthException.
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang;
|
||||
package org.springframework.erlang;
|
||||
|
||||
/**
|
||||
* Base RuntimeException for errors that occur when executing OTP operations.
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang;
|
||||
package org.springframework.erlang;
|
||||
|
||||
import java.io.IOException;
|
||||
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang;
|
||||
package org.springframework.erlang;
|
||||
|
||||
/**
|
||||
* A "catch-all" exception type within the OtpException hierarchy
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.connection;
|
||||
package org.springframework.erlang.connection;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.net.UnknownHostException;
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.connection;
|
||||
package org.springframework.erlang.connection;
|
||||
|
||||
|
||||
import org.apache.commons.logging.Log;
|
||||
@@ -15,7 +15,7 @@
|
||||
*/
|
||||
|
||||
|
||||
package org.springframework.otp.erlang.connection;
|
||||
package org.springframework.erlang.connection;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpPeer;
|
||||
import com.ericsson.otp.erlang.OtpSelf;
|
||||
@@ -14,13 +14,13 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.connection;
|
||||
package org.springframework.erlang.connection;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.net.UnknownHostException;
|
||||
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.otp.erlang.OtpIOException;
|
||||
import org.springframework.erlang.OtpIOException;
|
||||
import org.springframework.util.Assert;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpAuthException;
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.core;
|
||||
package org.springframework.erlang.core;
|
||||
|
||||
/**
|
||||
* Describes an Erlang application. Only three fields are supported as that is the level
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.core;
|
||||
package org.springframework.erlang.core;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpConnection;
|
||||
|
||||
@@ -15,10 +15,10 @@
|
||||
*/
|
||||
|
||||
|
||||
package org.springframework.otp.erlang.core;
|
||||
package org.springframework.erlang.core;
|
||||
|
||||
import org.springframework.otp.erlang.OtpException;
|
||||
import org.springframework.otp.erlang.support.converter.ErlangConverter;
|
||||
import org.springframework.erlang.OtpException;
|
||||
import org.springframework.erlang.support.converter.ErlangConverter;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpErlangList;
|
||||
import com.ericsson.otp.erlang.OtpErlangObject;
|
||||
@@ -14,16 +14,16 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.core;
|
||||
package org.springframework.erlang.core;
|
||||
|
||||
import org.springframework.otp.erlang.ErlangErrorRpcException;
|
||||
import org.springframework.otp.erlang.ErlangBadRpcException;
|
||||
import org.springframework.otp.erlang.OtpException;
|
||||
import org.springframework.otp.erlang.connection.ConnectionFactory;
|
||||
import org.springframework.otp.erlang.support.ErlangAccessor;
|
||||
import org.springframework.otp.erlang.support.ErlangUtils;
|
||||
import org.springframework.otp.erlang.support.converter.ErlangConverter;
|
||||
import org.springframework.otp.erlang.support.converter.SimpleErlangConverter;
|
||||
import org.springframework.erlang.ErlangBadRpcException;
|
||||
import org.springframework.erlang.ErlangErrorRpcException;
|
||||
import org.springframework.erlang.OtpException;
|
||||
import org.springframework.erlang.connection.ConnectionFactory;
|
||||
import org.springframework.erlang.support.ErlangAccessor;
|
||||
import org.springframework.erlang.support.ErlangUtils;
|
||||
import org.springframework.erlang.support.converter.ErlangConverter;
|
||||
import org.springframework.erlang.support.converter.SimpleErlangConverter;
|
||||
import org.springframework.util.Assert;
|
||||
|
||||
import com.ericsson.otp.erlang.*;
|
||||
@@ -122,7 +122,7 @@ public class ErlangTemplate extends ErlangAccessor implements ErlangOperations {
|
||||
throw convertOtpAccessException(ex);
|
||||
}
|
||||
finally {
|
||||
org.springframework.otp.erlang.connection.ConnectionFactoryUtils.releaseConnection(con, getConnectionFactory());
|
||||
org.springframework.erlang.connection.ConnectionFactoryUtils.releaseConnection(con, getConnectionFactory());
|
||||
}
|
||||
|
||||
|
||||
@@ -134,10 +134,10 @@ public class ErlangTemplate extends ErlangAccessor implements ErlangOperations {
|
||||
* Convert the specified checked exception to
|
||||
* a Spring runtime exception equivalent.
|
||||
* <p>The default implementation delegates to the
|
||||
* {@link org.springframework.otp.erlang.support.ErlangUtils#convertOtpAccessException} method.
|
||||
* {@link org.springframework.erlang.support.ErlangUtils#convertOtpAccessException} method.
|
||||
* @param ex the original checked {@link Exception} to convert
|
||||
* @return the Spring runtime wrapping <code>ex</code>
|
||||
* @see org.springframework.otp.erlang.support.ErlangUtils#convertOtpAccessException
|
||||
* @see org.springframework.erlang.support.ErlangUtils#convertOtpAccessException
|
||||
*/
|
||||
protected OtpException convertOtpAccessException(Exception ex) {
|
||||
return ErlangUtils.convertOtpAccessException(ex);
|
||||
@@ -17,7 +17,7 @@
|
||||
/**
|
||||
* Describes an Erlang node.
|
||||
*/
|
||||
package org.springframework.otp.erlang.core;
|
||||
package org.springframework.erlang.core;
|
||||
|
||||
/**
|
||||
* Simple description class for an Erlang node.
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.support;
|
||||
package org.springframework.erlang.support;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.net.UnknownHostException;
|
||||
@@ -23,8 +23,8 @@ import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.otp.erlang.OtpException;
|
||||
import org.springframework.otp.erlang.connection.ConnectionFactory;
|
||||
import org.springframework.erlang.OtpException;
|
||||
import org.springframework.erlang.connection.ConnectionFactory;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpAuthException;
|
||||
import com.ericsson.otp.erlang.OtpConnection;
|
||||
@@ -14,13 +14,13 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.support;
|
||||
package org.springframework.erlang.support;
|
||||
|
||||
import java.io.IOException;
|
||||
|
||||
import org.springframework.otp.erlang.OtpException;
|
||||
import org.springframework.otp.erlang.OtpIOException;
|
||||
import org.springframework.otp.erlang.UncategorizedOtpException;
|
||||
import org.springframework.erlang.OtpException;
|
||||
import org.springframework.erlang.OtpIOException;
|
||||
import org.springframework.erlang.UncategorizedOtpException;
|
||||
import org.springframework.util.Assert;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpConnection;
|
||||
@@ -14,9 +14,9 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.support.converter;
|
||||
package org.springframework.erlang.support.converter;
|
||||
|
||||
import org.springframework.otp.erlang.OtpException;
|
||||
import org.springframework.erlang.OtpException;
|
||||
|
||||
/**
|
||||
* @author Mark Pollack
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.support.converter;
|
||||
package org.springframework.erlang.support.converter;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpErlangObject;
|
||||
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.otp.erlang.support.converter;
|
||||
package org.springframework.erlang.support.converter;
|
||||
|
||||
import java.util.ArrayList;
|
||||
|
||||
@@ -31,11 +31,11 @@ import org.springframework.amqp.rabbit.core.ChannelCallback;
|
||||
import org.springframework.amqp.rabbit.core.RabbitAdmin;
|
||||
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
||||
import org.springframework.core.task.SimpleAsyncTaskExecutor;
|
||||
import org.springframework.erlang.connection.SimpleConnectionFactory;
|
||||
import org.springframework.erlang.core.ErlangTemplate;
|
||||
import org.springframework.jmx.export.annotation.ManagedOperation;
|
||||
import org.springframework.jmx.export.annotation.ManagedOperationParameter;
|
||||
import org.springframework.jmx.export.annotation.ManagedOperationParameters;
|
||||
import org.springframework.otp.erlang.connection.SimpleConnectionFactory;
|
||||
import org.springframework.otp.erlang.core.ErlangTemplate;
|
||||
import org.springframework.util.Assert;
|
||||
import org.springframework.util.exec.Execute;
|
||||
import org.springframework.util.exec.Os;
|
||||
@@ -308,7 +308,7 @@ public class RabbitBrokerAdmin implements RabbitBrokerOperations {
|
||||
createErlangTemplate(otpCf);
|
||||
}
|
||||
|
||||
protected void createErlangTemplate(org.springframework.otp.erlang.connection.ConnectionFactory otpCf) {
|
||||
protected void createErlangTemplate(org.springframework.erlang.connection.ConnectionFactory otpCf) {
|
||||
erlangTemplate = new ErlangTemplate(otpCf);
|
||||
erlangTemplate.setErlangConverter(new RabbitControlErlangConverter());
|
||||
erlangTemplate.afterPropertiesSet();
|
||||
|
||||
@@ -25,11 +25,11 @@ import java.util.Map;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
|
||||
import org.springframework.otp.erlang.core.Application;
|
||||
import org.springframework.otp.erlang.core.Node;
|
||||
import org.springframework.otp.erlang.support.converter.ErlangConversionException;
|
||||
import org.springframework.otp.erlang.support.converter.ErlangConverter;
|
||||
import org.springframework.otp.erlang.support.converter.SimpleErlangConverter;
|
||||
import org.springframework.erlang.core.Application;
|
||||
import org.springframework.erlang.core.Node;
|
||||
import org.springframework.erlang.support.converter.ErlangConversionException;
|
||||
import org.springframework.erlang.support.converter.ErlangConverter;
|
||||
import org.springframework.erlang.support.converter.SimpleErlangConverter;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpErlangAtom;
|
||||
import com.ericsson.otp.erlang.OtpErlangBinary;
|
||||
|
||||
@@ -18,8 +18,8 @@ package org.springframework.amqp.rabbit.admin;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import org.springframework.otp.erlang.core.Application;
|
||||
import org.springframework.otp.erlang.core.Node;
|
||||
import org.springframework.erlang.core.Application;
|
||||
import org.springframework.erlang.core.Node;
|
||||
|
||||
/**
|
||||
* The status object returned from querying the broker
|
||||
|
||||
@@ -23,7 +23,7 @@ import org.springframework.amqp.rabbit.admin.RabbitBrokerAdmin;
|
||||
import org.springframework.amqp.rabbit.admin.RabbitStatus;
|
||||
import org.springframework.amqp.rabbit.connection.SingleConnectionFactory;
|
||||
import org.springframework.core.annotation.AnnotationUtils;
|
||||
import org.springframework.otp.erlang.OtpIOException;
|
||||
import org.springframework.erlang.OtpIOException;
|
||||
import org.springframework.test.context.TestContext;
|
||||
import org.springframework.test.context.support.AbstractTestExecutionListener;
|
||||
import org.springframework.test.context.transaction.TransactionConfiguration;
|
||||
|
||||
@@ -7,8 +7,8 @@ import java.net.UnknownHostException;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import org.springframework.otp.erlang.connection.SimpleConnectionFactory;
|
||||
import org.springframework.otp.erlang.core.ErlangTemplate;
|
||||
import org.springframework.erlang.connection.SimpleConnectionFactory;
|
||||
import org.springframework.erlang.core.ErlangTemplate;
|
||||
|
||||
import com.ericsson.otp.erlang.OtpAuthException;
|
||||
import com.ericsson.otp.erlang.OtpConnection;
|
||||
|
||||
@@ -26,7 +26,7 @@ import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import org.springframework.amqp.rabbit.connection.SingleConnectionFactory;
|
||||
import org.springframework.otp.erlang.OtpIOException;
|
||||
import org.springframework.erlang.OtpIOException;
|
||||
|
||||
/**
|
||||
* @author Mark Pollack
|
||||
|
||||
Reference in New Issue
Block a user