class FiamAnalyticsConnectorListener implements AnalyticsConnectorListener {

  @Override
  public void onMessageTriggered(int id, Bundle extras) {
    if (id == AnalyticsConstants.FIAM_ANALYTICS_CONNECTOR_LISTENER_EVENT_ID) {
      emitter.onNext(extras.getString("events"));
    }
  }

    FiamAnalyticsConnectorListener(FlowableEmitter<String> emitter);

}