Embedded Adapter Introduction

StreamBase provides a number of embedded adapters that you can use within your application. Embedded adapters run in the same JVM engine process that is hosting and processing your StreamBase EventFlow fragment. This configuration eliminates the client-server communication overhead that would incur if using an external adapter.

Embedded adapters start and stop automatically with the hosting EventFlow fragment, which simplifies many administration tasks. In StreamBase Studio, you can define the properties for each embedded adapter that you drag and drop into the EventFlow diagram.

To learn about each of the embedded and external adapters available from StreamBase, see the Adapters Guide. To learn how to create your own custom embedded adapters, see the API Guide.

Adding an Embedded Adapter to an EventFlow Module

To add an embedded adapter to an EventFlow fragment:

  1. Open the EventFlow module of interest in the EventFlow Editor.

  2. Drag the Adapter, Java Operator icon () from the Palette view's Operators and Adapters drawer onto the EventFlow canvas.

  3. Select the adapter you want from the dialog that opens. You can type filter text to narrow the list of adapters and operators to help locate the adapter of interest.

    • If you are using one of the embedded adapters installed with StreamBase, look in the Global folder in the Insert Operator or Adapter dialog.

    • If you are adding a custom adapter, look in the Project folder.

  4. Click OK to place the adapter icon on the canvas.

  5. Double-click the adapter in the EventFlow Editor to open its Properties view. Specify various adapter properties in the tabs provided, as described in the Adapters Guide page for the selected adapter.

  6. Connect the adapter to the appropriate components, according to the flow you want.

  7. Save and run the fragment.

    Note

    Adapters that connect to a third-party market feed or bus generally need a direct connection to an instance of that market feed or bus to allow testing.