This is an automated email from the ASF dual-hosted git repository.
tabish pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-protonj2.git
The following commit(s) were added to refs/heads/main by this push:
new fe03715 PROTON-2398 Fix a couple spelling in error messages and
internal types
fe03715 is described below
commit fe037157563e459550e3b7e2913536d0ccb1cce6
Author: Timothy Bish <tabish...@gmail.com>
AuthorDate: Tue Aug 17 17:53:30 2021 -0400
PROTON-2398 Fix a couple spelling in error messages and internal types
---
.../protonj2/engine/impl/ProtonConnection.java | 4 ++--
.../qpid/protonj2/engine/impl/ProtonEngine.java | 2 +-
.../protonj2/engine/impl/ProtonEnginePipeline.java | 22 +++++++++++-----------
3 files changed, 14 insertions(+), 14 deletions(-)
diff --git
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonConnection.java
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonConnection.java
index 089046b..1e5d11b 100644
---
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonConnection.java
+++
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonConnection.java
@@ -424,7 +424,7 @@ public class ProtonConnection extends
ProtonEndpoint<Connection> implements Conn
@Override
public void handleSASLHeader(AMQPHeader header, ProtonEngine context) {
- context.engineFailed(new ProtocolViolationException("Receivded
unexpected SASL Header"));
+ context.engineFailed(new ProtocolViolationException("Received
unexpected SASL Header"));
}
@Override
@@ -722,7 +722,7 @@ public class ProtonConnection extends
ProtonEndpoint<Connection> implements Conn
}
// We didn't find one that isn't free and also not awaiting remote
being / end
- // so just use an overlap as it should complete in order unles the
remote has
+ // so just use an overlap as it should complete in order unless the
remote has
// completely ignored the specification and or gone of the rails.
for (int i = 0; i <= localOpen.getChannelMax(); ++i) {
if (!localSessions.containsKey(i)) {
diff --git
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonEngine.java
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonEngine.java
index c6ba04c..6b3e3df 100644
---
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonEngine.java
+++
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonEngine.java
@@ -83,7 +83,7 @@ public class ProtonEngine implements Engine {
private BiConsumer<ProtonBuffer, Runnable> outputHandler;
private EventHandler<Engine> engineShutdownHandler;
private EventHandler<Engine> engineFailureHandler = (engine) -> {
- LOG.warn("Engine encounted error and will become inoperable: ",
engine.failureCause());
+ LOG.warn("Engine encountered error and will become inoperable: ",
engine.failureCause());
};
@Override
diff --git
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonEnginePipeline.java
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonEnginePipeline.java
index 01df8ba..f4ac3ae 100644
---
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonEnginePipeline.java
+++
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonEnginePipeline.java
@@ -33,8 +33,8 @@ import
org.apache.qpid.protonj2.engine.exceptions.ProtonException;
*/
public class ProtonEnginePipeline implements EnginePipeline {
- EngineHandlerContextReadBoundry head;
- EngineHandlerContextWriteBoundry tail;
+ EngineHandlerContextReadBoundary head;
+ EngineHandlerContextWriteBoundary tail;
private final ProtonEngine engine;
@@ -45,8 +45,8 @@ public class ProtonEnginePipeline implements EnginePipeline {
this.engine = engine;
- head = new EngineHandlerContextReadBoundry();
- tail = new EngineHandlerContextWriteBoundry();
+ head = new EngineHandlerContextReadBoundary();
+ tail = new EngineHandlerContextWriteBoundary();
// Ensure Pipeline starts out empty but initialized.
head.next = tail;
@@ -391,10 +391,10 @@ public class ProtonEnginePipeline implements
EnginePipeline {
//----- Synthetic handler context that bounds the pipeline
- private class EngineHandlerContextReadBoundry extends
ProtonEngineHandlerContext {
+ private class EngineHandlerContextReadBoundary extends
ProtonEngineHandlerContext {
- public EngineHandlerContextReadBoundry() {
- super("Read Boundry", engine, new BoundryEngineHandler());
+ public EngineHandlerContextReadBoundary() {
+ super("Read Boundary", engine, new BoundaryEngineHandler());
}
@Override
@@ -418,10 +418,10 @@ public class ProtonEnginePipeline implements
EnginePipeline {
}
}
- private class EngineHandlerContextWriteBoundry extends
ProtonEngineHandlerContext {
+ private class EngineHandlerContextWriteBoundary extends
ProtonEngineHandlerContext {
- public EngineHandlerContextWriteBoundry() {
- super("Write Boundry", engine, new BoundryEngineHandler());
+ public EngineHandlerContextWriteBoundary() {
+ super("Write Boundary", engine, new BoundaryEngineHandler());
}
@Override
@@ -455,7 +455,7 @@ public class ProtonEnginePipeline implements EnginePipeline
{
//----- Default TransportHandler Used at the pipeline boundary
- private class BoundryEngineHandler implements EngineHandler {
+ private class BoundaryEngineHandler implements EngineHandler {
@Override
public void engineStarting(EngineHandlerContext context) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
