Package com.bloomberglp.blpapi.test

Class TestUtil

java.lang.Object

com.bloomberglp.blpapi.test.TestUtil

public final class TestUtil
extends Object

This class (along with MessageFormatter) provides static utility for unit testing BLPAPI applications.

This component defines a class, TestUtil, that provides helpers unit-testing BLPAPI. This includes deserializing services, creating test events, and appending/formatting messages in these events.

Usage
-----
Example: Create subscription data with correlation id:
- - - - - - - - - - - - - - - - - - - - - - - - - - -
For the purpose of unit testing the behavior of tick processing, create a subscription data event containing a single tick for a given subscription, identified with a correlation id CorrelationID that is available in the test.

First create the service from a string:

  String schema ="<ServiceDefinition name=...>...</ServiceDefinition>";
  InputStream stream = new ByteArrayInputStream(
          schema.getBytes(Charset.forName("UTF-8")));
  Service service = TestUtil.deserializeService(stream);

  // Then create a subscription event
  Event event = TestUtil.createEvent(Event.EventType.SUBSCRIPTION_DATA);

  // Prepare the message properties:
  MessageProperties properties = new MessageProperties();
  properties.setCorrelationId(correlationId);

  // Then, obtain the definition for the message from the schema:
  Name msgName = new Name("MarketDataEvents");
  SchemaElementDefinition def = service.getEventDefinition(msgName);

  // Now append a message and obtain a formatter:
  MessageFormatter fmt = TestUtil.appendMessage(event, def, properties);
 

The formatter can now be used to fill in the data to be used in the test.

Note that service creation and the definitions for the ticks can be shared by all of the unit tests that need to create the same type of events.

Constructor Summary

Constructors

Constructor	Description
TestUtil()

Method Summary

Modifier and Type	Method	Description
static MessageFormatter	appendMessage(Event event, SchemaElementDefinition elementDef)	Creates a new message and appends it to the specified Event with default MessageProperties.
static MessageFormatter	appendMessage(Event event, SchemaElementDefinition elementDef, MessageProperties properties)	Creates a new message and appends it to the specified Event.
static Event	createEvent(Event.EventType eventType)	Creates and returns an Event to be used for testing with the specified eventType.
static Topic	createTopic(Service service, boolean isActive)	Creates a valid Topic with the specified service to support testing publishers.
static Service	deserializeService(InputStream inputStream)	Creates a Service object from the specified inputStream.
static SchemaElementDefinition	getAdminMessageDefinition(Name messageName)	Returns the definition for an admin message of the specified messageName.

Methods inherited from class java.lang.Object

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

Constructor Details

TestUtil

public TestUtil()

Method Details

createEvent

public static Event createEvent(Event.EventType eventType)

Creates and returns an Event to be used for testing with the specified eventType. The returned Event cannot be used for publishing. The behavior is undefined if EventFormatter is used with the returned Event.

Parameters:

eventType - an Event.EventType type of event.

Returns:

an Event of the requested type.

appendMessage

public static MessageFormatter appendMessage(Event event,
 SchemaElementDefinition elementDef)

Creates a new message and appends it to the specified Event with default MessageProperties.

Parameters:

event - an Event created from createEvent(com.bloomberglp.blpapi.Event.EventType).

elementDef - a SchemaElementDefinition that provides schema for the messages to be encoded.

Throws:

IllegalArgumentException - when fails to append message.

See Also:

• appendMessage(Event, SchemaElementDefinition, MessageProperties)

appendMessage

public static MessageFormatter appendMessage(Event event,
 SchemaElementDefinition elementDef,
 MessageProperties properties)

Creates a new message and appends it to the specified Event. Returns a MessageFormatter to format the last appended message. The specified Event must be a test Event created from createEvent(com.bloomberglp.blpapi.Event.EventType). elementDef is used to verify and encode the contents of the message and the specified properties are used to set the metadata properties for the message. An exception is thrown if the method fails to append the message.

Parameters:

event - an Event created from createEvent(com.bloomberglp.blpapi.Event.EventType).

elementDef - a SchemaElementDefinition that provides schema for the messages to be encoded.

properties - a MessageProperties that represents the metadata to be added to the appended message.

Throws:

IllegalArgumentException - when fails to append message.

deserializeService

public static Service deserializeService(InputStream inputStream)

Creates a Service object from the specified inputStream. The format of the inputStream must be XML. The inputStream should only contain ASCII characters without any embedded null characters. Returns the Service object on success or throws on failure.

Parameters:

inputStream - an InputStream that provides an XML, ASCII representation of Service.

Throws:

IllegalArgumentException - when inputStream is null.

RuntimeException - when fails to deserialize.

createTopic

public static Topic createTopic(Service service,
 boolean isActive)

Creates a valid Topic with the specified service to support testing publishers. The expected use case is to support returning a custom Topic while mocking ProviderSession.getTopic(com.bloomberglp.blpapi.Message) methods. The behavior is undefined if service is not created from deserializeService(InputStream).

Parameters:

service - a Service for which the custom topic will be created.

isActive - specifies whether or not the Topic is still active(not deleted).

getAdminMessageDefinition

public static SchemaElementDefinition getAdminMessageDefinition(Name messageName)

Returns the definition for an admin message of the specified messageName.

Parameters:

messageName - name of the requested message.

Throws:

IllegalArgumentException - if message name is null.

NotFoundException - if the schema definition for the messageName is not found.