Package com.persequor.event

Interface ICassandraEventsQuery<T extends IRepositoryEventsQuery<T>>

public interface ICassandraEventsQuery<T extends IRepositoryEventsQuery<T>>

  • Method Summary

    Modifier and Type
    Method
    Description
    T
    byBizTransaction(String bizTransactionType, String... bizTransactions)
    Keep only events in result which have their business transaction type matching the provided one and business transaction value in the provided collection.
    T
    byBizTransaction(String bizTransactionType, Collection<String> bizTransactions)
    Keep only events which have their business transaction type matching the provided one and business transaction value in the provided collection.
    T
    byDestination(String destinationType, String... destinations)
    Keep only events in result which have their destination type matching the provided one and destination value in the provided collection.
    T
    byDestination(String destinationType, Collection<String> destinations)
    Keep only events in result which have their destination type matching the provided one and destination value in the provided collection.
    T
    byEpcisEventId(String... ids)
    Filter this query by any of these epcis event ids.
    T
    byMatchAnyEPC(String... anyEpcs)
    Filter this query by any of these EPCs in childEpc, parentId, inputEpc and epcList
    T
    byMatchAnyEPC(Collection<String> anyEpcs)
    Filter this query by any of these EPCs in childEpc, parentId, inputEpc and epcList
    T
    byMatchAnyEpcClass(Collection<String> epcClasses)
    Filter by EPC classes from both input and output quantityList
    T
    byMatchEpc(String... epc)
    Filter this query by any of these EPCs
    T
    byMatchEpc(Collection<String> epc)
    Filter this query by any of these EPCs.
    T
    byMatchEpcClass(Collection<String> epcClasses)
    Filter by EPC classes from extension/quantityList/quantityElement/epcClass
    T
    byMatchParentID(String... epcs)
    Filter this query by any of these parentIds.
    T
    byMatchParentID(Collection<String> epcs)
    Filter this query by any of these parentIds.
    T
    bySagaEventId(UUID... ids)
    Filter this query by any of these epcis event ids.
    T
    bySource(String sourceType, String... sources)
    Filter this query by any of these Sources.
    T
    bySource(String sourceType, Collection<String> sources)
    Filter this query by any of these Sources.
    T
    filterRevertedEvents(boolean enableFilter)
    Explicitly set the filter option for reverted events, to override the default set in the saga configuration

  • Method Details

    • byMatchParentID

      T byMatchParentID(Collection<String> epcs)
      Filter this query by any of these parentIds. Setting this will also remove events without a parentId
      Parameters:
      epcs - parent ids allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchParentID

      T byMatchParentID(String... epcs)
      Filter this query by any of these parentIds. Setting this will also remove events without a parentId
      Parameters:
      epcs - parent ids allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchEpc

      T byMatchEpc(Collection<String> epc)
      Filter this query by any of these EPCs.
      Parameters:
      epc - allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchEpc

      T byMatchEpc(String... epc)
      Filter this query by any of these EPCs
      Parameters:
      epc - allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchAnyEPC

      T byMatchAnyEPC(Collection<String> anyEpcs)
      Filter this query by any of these EPCs in childEpc, parentId, inputEpc and epcList
      Parameters:
      anyEpcs - allowed in the result
      Returns:
      this query instance
      See Also:

    • byMatchAnyEPC

      T byMatchAnyEPC(String... anyEpcs)
      Filter this query by any of these EPCs in childEpc, parentId, inputEpc and epcList
      Parameters:
      anyEpcs - allowed in the result
      Returns:
      this query instance
      See Also:

    • byBizTransaction

      T byBizTransaction(String bizTransactionType, Collection<String> bizTransactions)
      Keep only events which have their business transaction type matching the provided one and business transaction value in the provided collection.
      Parameters:
      bizTransactionType - allowed business transaction type in the result
      bizTransactions - allowed business transaction values in the result
      Returns:
      this query instance
      See Also:

    • byBizTransaction

      T byBizTransaction(String bizTransactionType, String... bizTransactions)
      Keep only events in result which have their business transaction type matching the provided one and business transaction value in the provided collection.
      Parameters:
      bizTransactionType - allowed business transaction type in the result
      bizTransactions - allowed business transaction values in the result
      Returns:
      this query instance
      See Also:

    • bySource

      T bySource(String sourceType, Collection<String> sources)
      Filter this query by any of these Sources.
      Parameters:
      sourceType - allowed source type in the result
      sources - allowed source values in the result
      Returns:
      this query instance
      See Also:

    • bySource

      T bySource(String sourceType, String... sources)
      Filter this query by any of these Sources.
      Parameters:
      sourceType - allowed source type in the result
      sources - allowed source values in the result
      Returns:
      this query instance
      See Also:

    • byDestination

      T byDestination(String destinationType, Collection<String> destinations)
      Keep only events in result which have their destination type matching the provided one and destination value in the provided collection.
      Parameters:
      destinationType - allowed destination type in the result
      destinations - allowed destination values in the result
      Returns:
      this query instance
      See Also:

    • byDestination

      T byDestination(String destinationType, String... destinations)
      Keep only events in result which have their destination type matching the provided one and destination value in the provided collection.
      Parameters:
      destinationType - allowed destination type in the result
      destinations - allowed destination values in the result
      Returns:
      this query instance
      See Also:

    • byMatchEpcClass

      T byMatchEpcClass(Collection<String> epcClasses)
      Filter by EPC classes from extension/quantityList/quantityElement/epcClass
      Parameters:
      epcClasses - allowed in the result
      Returns:
      this query instance

    • byMatchAnyEpcClass

      T byMatchAnyEpcClass(Collection<String> epcClasses)
      Filter by EPC classes from both input and output quantityList
      Parameters:
      epcClasses - allowed in the result
      Returns:
      this query instance

    • bySagaEventId

      T bySagaEventId(UUID... ids)
      Filter this query by any of these epcis event ids.
      Parameters:
      ids - epcis event ids allowed in the result
      Returns:
      this query instance

    • byEpcisEventId

      T byEpcisEventId(String... ids)
      Filter this query by any of these epcis event ids.
      Parameters:
      ids - epcis event ids allowed in the result
      Returns:
      this query instance

    • filterRevertedEvents

      T filterRevertedEvents(boolean enableFilter)
      Explicitly set the filter option for reverted events, to override the default set in the saga configuration
      Parameters:
      enableFilter - sets whether or not to filter reverted events from the query result
      Returns:
      this query instance