de.hybris.platform.test

Class BroadcastServiceTest

java.lang.Object

de.hybris.platform.testframework.HybrisJUnit4Test

de.hybris.platform.test.BroadcastServiceTest

@IntegrationTest
public class BroadcastServiceTest
extends HybrisJUnit4Test

Test UDPBroadcastMethod by causing a item modification and listening to the message by creating a second broadcast method instance.

Field Summary

Fields inherited from class de.hybris.platform.testframework.HybrisJUnit4Test

defaultLanguage, jaloSession

Constructor Summary

Constructors

Constructor and Description
BroadcastServiceTest()

Method Summary

Modifier and Type	Method and Description
void	testInvalidationViaUDP()
void	testLoopBackMethod()
void	testMessageSendingQueue() Tests PLA-8550: whenever the message sending queue was filled up the calling thread did not block for the specified time but got a error immediately.
void	testOneLargeUDPPacket()
void	testRandomPacketSizesAndPacketAmounts()

Methods inherited from class de.hybris.platform.testframework.HybrisJUnit4Test

finish, getOrCreateCurrency, getOrCreateLanguage, init, intenseChecksActivated

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BroadcastServiceTest

public BroadcastServiceTest()

Method Detail

testLoopBackMethod

public void testLoopBackMethod()
                        throws UnknownHostException,
                               InterruptedException

Throws:

UnknownHostException

InterruptedException

testInvalidationViaUDP

public void testInvalidationViaUDP()

testMessageSendingQueue

public void testMessageSendingQueue()

Tests PLA-8550: whenever the message sending queue was filled up the calling thread did not block for the specified time but got a error immediately.

So the tests tries to send considerably more messages than queue size could allow and tries to get that error again. If the test finished the error must be fixed.

testOneLargeUDPPacket

public void testOneLargeUDPPacket()
                           throws InterruptedException

Throws:

InterruptedException

testRandomPacketSizesAndPacketAmounts

public void testRandomPacketSizesAndPacketAmounts()
                                           throws InterruptedException

Throws:

InterruptedException