Projects >> spring-amqp >>2e1994950461af8b35c4a18b90f9463402561ddc

Chunk
Conflicting content 
	}

	@Test
<<<<<<< HEAD
	@Ignore("Caused by: OtpIOException: failed to connect from 'rabbit-spring-monitor' to peer node 'localhost'")
	public void integrationTestsUserCrud() {
=======
	// @Ignore
	public void integrationTestsUserCrud() throws Exception {
>>>>>>> bd8139948757e7c3fac5363a81e0754264c5ff10
		List users = brokerAdmin.listUsers();
		if (users.contains("joe")) {
			brokerAdmin.deleteUser("joe");
Solution content 
	}

	@Test
	// @Ignore
	public void integrationTestsUserCrud() throws Exception {
		List users = brokerAdmin.listUsers();
		if (users.contains("joe")) {
			brokerAdmin.deleteUser("joe");
File
RabbitBrokerAdminIntegrationTests.java
Developer's decision
Version 2
Kind of conflict
Annotation
Comment
Method signature
Chunk
Conflicting content 
		}
	}

<<<<<<< HEAD

	public void integrationTestListUsers() {
		// OtpErlangObject result =
		// adminTemplate.getErlangTemplate().executeRpc("rabbit_amqqueue",
		// "info_all", "/".getBytes());
		// System.out.println(result);
		List users = brokerAdmin.listUsers();
		System.out.println(users);
	}

	public void integrationTestDeleteUser() {
		// OtpErlangObject result =
		// adminTemplate.getErlangTemplate().executeRpc("rabbit_access_control",
		// "delete_user", "joe".getBytes());
		brokerAdmin.deleteUser("joe");
		// System.out.println(result.getClass());
		// System.out.println(result);
	}

	@Test
	@Ignore("Caused by: OtpIOException: failed to connect from 'rabbit-spring-monitor' to peer node 'localhost'")
	public void testStatusAndBrokerLifecycle() {
		RabbitStatus status = brokerAdmin.getStatus();
		assertBrokerAppRunning(status);
=======
	@Test
	public void repeatLifecycle() throws Exception {
		for (int i = 1; i < 20; i++) {
			testStatusAndBrokerLifecycle();
			if (i % 5 == 0) {
				logger.debug("i = " + i);
			}
		}
	}

	// @Test
	public void testStatusAndBrokerLifecycle() throws Exception {

		RabbitStatus status = brokerAdmin.getStatus();
>>>>>>> bd8139948757e7c3fac5363a81e0754264c5ff10

		brokerAdmin.stopBrokerApplication();
		status = brokerAdmin.getStatus();
Solution content 
		}
	}

	@Test
	public void repeatLifecycle() throws Exception {
		for (int i = 1; i < 20; i++) {
			testStatusAndBrokerLifecycle();
			if (i % 5 == 0) {
				logger.debug("i = " + i);
			}
		}
	}

	// @Test
	public void testStatusAndBrokerLifecycle() throws Exception {

		RabbitStatus status = brokerAdmin.getStatus();

		brokerAdmin.stopBrokerApplication();
		status = brokerAdmin.getStatus();
File
RabbitBrokerAdminIntegrationTests.java
Developer's decision
Version 2
Kind of conflict
Annotation
Comment
Method declaration
Method invocation
Method signature
Variable
Chunk
Conflicting content 
		assertBrokerAppRunning(status);
	}

<<<<<<< HEAD
	@Test
	@Ignore("NEEDS RABBITMQ_HOME to be set.")
	public void testStartNode() {
		try {
			brokerAdmin.stopNode();
		} catch (OtpIOException e) {
			//assume it is not running.
		}
		brokerAdmin.startNode();
		assertEquals(1,1);
		brokerAdmin.stopNode();
	}

	@Test
	@Ignore("Caused by: java.io.IOException: Nameserver not responding on anakata.local when looking up rabbit")
	public void testGetQueues() {
=======
	@Test
	public void testGetQueues() throws Exception {
>>>>>>> bd8139948757e7c3fac5363a81e0754264c5ff10
		brokerAdmin.declareQueue(new Queue("test.queue"));
		assertEquals("/", connectionFactory.getVirtualHost());
		List queues = brokerAdmin.getQueues();
Solution content 
		assertBrokerAppRunning(status);
	}

	@Test
	public void testGetQueues() throws Exception {
		brokerAdmin.declareQueue(new Queue("test.queue"));
		assertEquals("/", connectionFactory.getVirtualHost());
		List queues = brokerAdmin.getQueues();
File
RabbitBrokerAdminIntegrationTests.java
Developer's decision
Version 2
Kind of conflict
Annotation
Method declaration
Method signature