Skip to content

Commit

Permalink
Typo fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
katajakasa committed Aug 27, 2017
1 parent a95668a commit edc26ec
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 9 deletions.
6 changes: 3 additions & 3 deletions pika/adapters/blocking_connection.py
Expand Up @@ -95,7 +95,7 @@ def signal_once(self, *_args, **_kwargs):
self._ready = True

def set_value_once(self, *args, **kwargs):
""" Set as ready with value; the value may be retrived via the `value`
""" Set as ready with value; the value may be retrieved via the `value`
property getter
:raises AssertionError: if result was already set
Expand Down Expand Up @@ -696,7 +696,7 @@ def process_data_events(self, time_limit=0):
seconds. The actual blocking time depends on the granularity of the
underlying ioloop. Zero means return as soon as possible. None means
there is no limit on processing time and the function will block
until I/O produces actionalable events. Defaults to 0 for backward
until I/O produces actionable events. Defaults to 0 for backward
compatibility. This parameter is NEW in pika 0.10.0.
"""
with self._acquire_event_dispatch() as dispatch_acquired:
Expand Down Expand Up @@ -1077,7 +1077,7 @@ class BlockingChannel(object):
'BlockingChannel__OnMessageConfirmationReportArgs',
'method_frame')

# Parameters for broker-inititated Channel.Close request: reply_code
# Parameters for broker-initiated Channel.Close request: reply_code
# holds the broker's non-zero error code and reply_text holds the
# corresponding error message text.
_OnChannelClosedByBrokerArgs = namedtuple(
Expand Down
12 changes: 6 additions & 6 deletions pika/connection.py
Expand Up @@ -183,7 +183,7 @@ def __repr__(self):
@property
def backpressure_detection(self):
"""
:returns: boolean indicatating whether backpressure detection is
:returns: boolean indicating whether backpressure detection is
enabled. Defaults to `DEFAULT_BACKPRESSURE_DETECTION`.
"""
Expand All @@ -192,7 +192,7 @@ def backpressure_detection(self):
@backpressure_detection.setter
def backpressure_detection(self, value):
"""
:param bool value: boolean indicatating whether to enable backpressure
:param bool value: boolean indicating whether to enable backpressure
detection
"""
Expand Down Expand Up @@ -468,7 +468,7 @@ def socket_timeout(self, value):
"""
:param float value: socket timeout value; NOTE: this is mostly unused
now, owing to switchover to to non-blocking socket setting after
initial socket conection establishment.
initial socket connection establishment.
"""
if value is not None:
Expand Down Expand Up @@ -603,7 +603,7 @@ def __init__(self, # pylint: disable=R0913,R0914,R0912
`reason_code` of `InternalCloseReasons.BLOCKED_CONNECTION_TIMEOUT`.
:type blocked_connection_timeout: None, int, float
:param client_properties: None or dict of client properties used to
override the fields in the default client poperties reported to
override the fields in the default client properties reported to
RabbitMQ via `Connection.StartOk` method.
:param heartbeat_interval: DEPRECATED; use `heartbeat` instead, and
don't pass both
Expand Down Expand Up @@ -699,7 +699,7 @@ class URLParameters(Parameters):
Override the default maximum channel count value
- client_properties:
dict of client properties used to override the fields in the default
client poperties reported to RabbitMQ via `Connection.StartOk`
client properties reported to RabbitMQ via `Connection.StartOk`
method
- connection_attempts:
Specify how many times pika should try and reconnect before it gives up
Expand Down Expand Up @@ -752,7 +752,7 @@ def __init__(self, url):
# Fix up scheme amqp(s) to http(s) so urlparse won't barf on python
# prior to 2.7. On Python 2.6.9,
# `urlparse('amqp://127.0.0.1/%2f?socket_timeout=1')` produces an
# incorect path='/%2f?socket_timeout=1'
# incorrect path='/%2f?socket_timeout=1'
if url[0:4].lower() == 'amqp':
url = 'http' + url[4:]

Expand Down

0 comments on commit edc26ec

Please sign in to comment.