Skip to content

Commit

Permalink
fix some wrong package names
Browse files Browse the repository at this point in the history
Signed-off-by: Stanchev Aleksandar <aleksandar.stanchev@bosch.com>
  • Loading branch information
alstanchev authored and Aleksandar Stanchev committed Aug 28, 2023
1 parent 3688eea commit baf14c5
Show file tree
Hide file tree
Showing 7 changed files with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ CompletionStage<Void> registerForConnectivityConfigChanges(ConnectionId connecti

/**
* Returns {@code true} if the implementation can handle the given {@code event} to generate a modified {@link ConnectivityConfig}
* when passed to {@link #handleEvent(org.eclipse.ditto.base.model.signals.events.Event, pekko.actor.ActorRef, pekko.actor.ActorRef)}.
* when passed to {@link #handleEvent(org.eclipse.ditto.base.model.signals.events.Event, org.apache.pekko.actor.ActorRef, org.apache.pekko.actor.ActorRef)}.
*
* @param event the event that may be used to generate modified config
* @return {@code true} if the event is compatible
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -444,8 +444,8 @@ private FSM.State<BaseClientState, BaseClientData> completeInitialization() {
}

/**
* Handles {@link TestConnection} commands by returning a CompletionState of {@link pekko.actor.Status.Status Status}
* which may be {@link pekko.actor.Status.Success Success} or {@link pekko.actor.Status.Failure Failure}.
* Handles {@link TestConnection} commands by returning a CompletionState of {@link org.apache.pekko.actor.Status.Status Status}
* which may be {@link org.apache.pekko.actor.Status.Success Success} or {@link org.apache.pekko.actor.Status.Failure Failure}.
*
* @param testConnectionCommand the Connection to test
* @return the CompletionStage with the test result
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,7 @@ private KafkaPublisherActor(final Connection connection,
}

/**
* Creates Akka configuration object {@link pekko.actor.Props} for this {@code BasePublisherActor}.
* Creates Akka configuration object {@link org.apache.pekko.actor.Props} for this {@code BasePublisherActor}.
*
* @param connection the connection this publisher belongs to.
* @param producerFactory factory to create kafka SendProducer.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
import org.apache.pekko.actor.Props;

/**
* Creates actor {@link pekko.actor.Props}.
* Creates actor {@link org.apache.pekko.actor.Props}.
*/
public interface ConnectionsRetrievalActorPropsFactory extends DittoExtensionPoint {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
import org.apache.pekko.stream.stage.GraphStageLogicWithLogging;

/**
* Extension of {@code pekko.stream.stage.GraphStageLogic} with Ditto-specific functions.
* Extension of {@link org.apache.pekko.stream.stage.GraphStageLogic} with Ditto-specific functions.
*
* @since 1.1.0
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
* <p>
* Behavior definition:
* <pre>{@code
* pekko.stream.scaladsl.MergeSorted
* org.apache.pekko.stream.scaladsl.MergeSorted
* }</pre>
* is behaviorally equivalent as stream component with
* <pre>{@code
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -432,7 +432,7 @@ protected CompletionStage<Object> askEnforcerChild(final Signal<?> signal) {
/**
* Asks the "target actor" (being either the {@link AbstractPersistenceActor} for "twin" commands or e.g. a
* pub/sub actor reference for "live" commands/messages) - which is determined by
* {@link #getTargetActorForSendingEnforcedMessageTo(Object, boolean, pekko.actor.ActorRef)} - the passed {@code message}.
* {@link #getTargetActorForSendingEnforcedMessageTo(Object, boolean, org.apache.pekko.actor.ActorRef)} - the passed {@code message}.
*
* @param message the message to ask the target actor.
* @param shouldSendResponse whether the message should send a response or not.
Expand Down

0 comments on commit baf14c5

Please sign in to comment.