@@ -12,11 +12,13 @@ import app.softnetwork.notification.persistence.typed.{
1212 AllNotificationsBehavior ,
1313 NotificationBehavior
1414}
15+ import app .softnetwork .persistence .jdbc .query .JdbcSchema .SchemaType
1516import app .softnetwork .persistence .jdbc .query .{JdbcJournalProvider , JdbcSchema , JdbcSchemaProvider }
16- import app .softnetwork .scheduler .api .SchedulerApi
1717import app .softnetwork .scheduler .config .SchedulerSettings
1818
19- trait AllNotificationsApi extends SchedulerApi with NotificationApplication [Notification ] {
19+ trait AllNotificationsApi extends NotificationApplication [Notification ] with JdbcSchemaProvider {
20+
21+ def internalSchemaType : SchemaType = this .schemaType
2022
2123 override def notificationBehaviors : ActorSystem [_] => Seq [NotificationBehavior [Notification ]] =
2224 _ => Seq (AllNotificationsBehavior )
@@ -30,7 +32,7 @@ trait AllNotificationsApi extends SchedulerApi with NotificationApplication[Noti
3032 with JdbcJournalProvider
3133 with JdbcSchemaProvider {
3234 override val tag : String = SchedulerSettings .tag(AllNotificationsBehavior .persistenceId)
33- override lazy val schemaType : JdbcSchema .SchemaType = jdbcSchemaType
35+ override lazy val schemaType : JdbcSchema .SchemaType = internalSchemaType
3436 override implicit val system : ActorSystem [_] = sys
3537 }
3638 )
@@ -43,7 +45,7 @@ trait AllNotificationsApi extends SchedulerApi with NotificationApplication[Noti
4345 with AllNotificationsHandler
4446 with JdbcJournalProvider
4547 with JdbcSchemaProvider {
46- override lazy val schemaType : JdbcSchema .SchemaType = jdbcSchemaType
48+ override lazy val schemaType : JdbcSchema .SchemaType = internalSchemaType
4749 override implicit def system : ActorSystem [_] = sys
4850 }
4951 )
0 commit comments