Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
yuz10 committed Jul 4, 2024
1 parent 1c7cf4d commit e520e7f
Showing 1 changed file with 1 addition and 7 deletions.
8 changes: 1 addition & 7 deletions python/rocketmq/simple_subscription_settings.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@

from google.protobuf.duration_pb2 import Duration
from rocketmq.filter_expression import ExpressionType
from rocketmq.filter_expression import FilterExpression
from rocketmq.log import logger
from rocketmq.protocol.definition_pb2 import \
FilterExpression as ProtoFilterExpression
Expand All @@ -30,13 +31,6 @@
from .settings import ClientType, ClientTypeHelper, Settings


# Assuming a simple representation of FilterExpression for the purpose of this example
class FilterExpression:
def __init__(self, type, expression):
self.type = type
self.Expression = expression


class SimpleSubscriptionSettings(Settings):

def __init__(self, clientId, endpoints, consumerGroup, requestTimeout, longPollingTimeout,
Expand Down

0 comments on commit e520e7f

Please sign in to comment.