Skip to content

Instantly share code, notes, and snippets.

@virajkulkarni14

virajkulkarni14/RabbitIntegrationTest.java

Forked from mosheeshel/RabbitIntegrationTest.java
Created May 27, 2020 00:06
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save virajkulkarni14/6b1eb4e3c7e5ed9d88e40336c54d3fc3 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save virajkulkarni14/6b1eb4e3c7e5ed9d88e40336c54d3fc3 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. @mosheeshel mosheeshel created this gist Oct 2, 2014.
    64 changes: 64 additions & 0 deletions RabbitIntegrationTest.java
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,64 @@
    package integration;

    import com.kenshoo.trackingfront.configuration.RabbitConfiguration;
    import com.kenshoo.trackingfront.rabbitmq.RabbitConnectionFactory;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    import org.junit.*;
    import org.junit.rules.ExpectedException;

    import static org.mockito.Matchers.anyString;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.when;

    /**
    * Created with IntelliJ IDEA.
    * User: moshe
    * Date: 9/23/14
    * Time: 1:48 PM
    */
    public class RabbitIntegrationTest {

    @ClassRule
    public static RabbitContainerRule rabbitContainerRule = new RabbitContainerRule();

    @Rule
    public ExpectedException expectedException = ExpectedException.none();

    private RabbitConnectionFactory rabbitConnectionFactory;
    private RabbitConfiguration rabbitConfiguration;
    private ConnectionFactory connectionFactory;


    @Before
    public void setUp() throws Exception {
    connectionFactory = new ConnectionFactory();
    rabbitConfiguration = mock(RabbitConfiguration.class);

    when(rabbitConfiguration.getExchange()).thenReturn("test.this.exchange");
    when(rabbitConfiguration.getVirtualHost()).thenReturn("/");
    when(rabbitConfiguration.getPassword()).thenReturn("guest");
    when(rabbitConfiguration.getUserName()).thenReturn("guest");
    when(rabbitConfiguration.getHosts()).thenReturn("127.0.0.1");
    when(rabbitConfiguration.getPort()).thenReturn(Integer.valueOf(rabbitContainerRule.getRabbitServicePort()));

    rabbitConnectionFactory = new RabbitConnectionFactory(rabbitConfiguration);

    System.out.println("servicePort " + rabbitContainerRule.getRabbitServicePort());
    System.out.println("managementPort " + rabbitContainerRule.getRabbitManagementPort());
    }


    @After
    public void tearDown() throws Exception {


    }

    @Test
    public void testConnectsToDocker() throws Exception {
    Connection connection = rabbitConnectionFactory.getConnection();
    System.out.println(connection.toString());
    }

    }